`

jdk6.0从入门到精通-----chapter8并发多线程(1)(源码下载)

阅读更多
服务器端使用线程池,每监听到一个请求,取出一个线程。当客户端输入stop时,消除线程池。
本例的线程池严格说算是线程数组,因为它丧失了两个很重要的网络服务器的特征:
1,主线程负责监听,一旦接入请求,将其转给线程池中空闲的线程处理,而自身继续监听客户端的连接请求。而本例中,主线程接入请求后继续负责调度线程池中线程处理客户端请求,这就导致了server只能接受一个client
2,线程池中线程一直处于运行状态

客户端
import java.net.*;
//连接服务器端口,并将用户的键盘输入发送给服务器
public class Commander
{
   public static void main(String[] args)
   {
      Socket socket=null;
      PrintWriter out = null;  
      try
      {
         socket = new Socket(args[0],Integer.parseInt(args[1]));  //ip+port
         out = new PrintWriter (socket.getOutputStream (), true);
         byte[] b = new byte[2048];
         String msg = new String(b,0,System.in.read(b));
         while(!msg.startsWith("stop"))
         { 
           out.println(msg);
           msg = new String(b,0,System.in.read(b)); //继续读入键盘输入
         }
         out.println(msg);  
      } 
      catch(Exception e)
      {
         e.printStackTrace();	
      }
      finally
      {
         try
         {
            if(socket!=null)
              socket.close();
         }
         catch(Exception e1)
         {
         }
      }  	  
   }
}

服务器端,
package ThreadPool1;

import java.io.*;
import java.lang.*;
import java.net.*;
import java.text.*;

class ThreadManager
{	
  TheThread[] runner=null;
  int count;
  boolean busy;
	
  public static void main(String[] args) throws IOException
  {	
    new ThreadManager(5).listen();
  }
  
  public ThreadManager(int count)
  {
    this.count=count;	
  }	
  
  private void listen() throws IOException
  {
    //建立线程池,启动所有线程
    runner=new TheThread[this.count];
    for(int i=0;i<this.count;i++)
    {
      runner[i]=new TheThread(i);
      runner[i].start();	
    }		
    //侦听1024端口
    ServerSocket serverSocket = new ServerSocket(1024);	
    Socket socket = serverSocket.accept();
    while(true)
    {
      try
      {
        BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        String cmd=in.readLine();
        if(cmd==null)
          break;
        if(cmd.startsWith("stop"))
        {
          for(int i=0;i<5;i++)
          {
            synchronized(runner[i])
            {
              Thread.sleep(500);
              runner[i].interrupt(); 	  
            }  	 	
          }
          System.out.println("线程池已被销毁,程序退出");
          break;
        }
        else
          synchronized(this)
          {
            busy=true;
            for(int i=0;i<5;i++)	
              if(runner[i].string==null)
              {
              	runner[i].string=cmd;
              	busy=false;
              	break;
              }
            if(busy)
              System.out.println("服务器正忙,线程池中没有空闲线程处理指令:"+cmd);  	  
          }  	  		  	  
      }
      catch(Exception e)
      {
        e.printStackTrace();	
      }	    
    }  	    	
  }		  	
}	
class TheThread extends Thread
{
  int no;
  public String string=null; 
  
  public TheThread(int i)
  {
    this.no=i;	
  }
  	
  public void run()
  {
    try	
    {
      while(true)
      { 
        Thread.sleep(1000);
        if(this.string!=null) 
          synchronized(this)
          {
            System.out.println("第"+no+"个线程处理指令:"+this.string);
            this.string=null;
          } 
      }
    }  
    catch(InterruptedException ie)
    {
      System.out.println("["+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new java.util.Date())+"] "+"线程"+this.no+"被中止...");
    }	     
  }  	    	
}
分享到:
评论

相关推荐

    jdk6.0从入门到精通-----chapter7线程

    《JDK 6.0线程入门到精通——Chapter 7》 在Java开发中,线程是程序执行的最小单元,它使得一个程序能够同时处理多个任务,从而提高了程序的效率和响应性。在JDK 6.0中,线程的管理和使用有了更加完善的特性,对于...

    jdk6.0从入门到精通-----chapter5网络编程 新I/O(含源码下载)

    在Java编程领域,JDK(Java Development Kit)是开发和运行Java应用程序的...总的来说,"JDK6.0从入门到精通-----chapter5网络编程 新I/O"是一个极好的学习资源,无论你是初学者还是有经验的开发者,都能从中获益良多。

    jdk6.0从入门到精通-----chapter17动态编程

    《JDK 6.0从入门到精通——Chapter 17 动态编程》 在Java编程领域,JDK 6.0版本引入了许多新特性,其中动态编程是提升开发效率和灵活性的重要方面。本章将深入探讨动态编程的概念、用途以及如何在JDK 6.0中利用这些...

    (源码下载)jdk6.0从入门到精通-----chapter2--输入输出,克隆对象

    标题 "(源码下载)jdk6.0从入门到精通-----chapter2--输入输出,克隆对象" 提供了我们要探讨的主题,即Java中的输入输出流(I/O Stream)和对象克隆。在这个章节中,我们将深入理解这两个关键概念。 **输入输出流...

    jdk6.0从入门到精通-----chapter18与动态语言结合

    标题中的“jdk6.0从入门到精通-----chapter18与动态语言结合”指的是Java开发工具包(JDK)6.0版本中的一个章节,主要探讨了如何将Java与动态编程语言集成。在Java 6中,引入了一个重要的特性,即Java平台标准版6...

    jdk6.0从入门到精通-----chapter4--文件目录操作

    在Java编程语言中,JDK(Java Development Kit)是核心组件,它包含了开发和运行Java应用程序所需的工具和...同时,随着Java版本的更新,如JDK 7和8引入了更多的文件操作改进,开发者也需要持续学习和掌握最新的技术。

    jdk6.0从入门到精通-----chapter16反射机制-spring AOP

    在Java编程领域,JDK6.0是一个重要的版本,它为开发者提供了丰富的特性和改进。本章我们将深入探讨“反射机制”以及如何结合Spring AOP(面向切面编程)进行应用。反射是Java中的一种强大工具,允许程序在运行时检查...

    jdk 6.0 jdk-6u10-rc2-bin-b32-windows-i586-p-12_sep_2008(微信开发平台开发JDK)

    微信开发平台开发工具 JDK jdk 6.0 jdk-6u10-rc2-bin-b32-windows-i586-p-12_sep_2008

    开发工具 jdk-8u121-windows-i586

    开发工具 jdk-8u121-windows-i586开发工具 jdk-8u121-windows-i586开发工具 jdk-8u121-windows-i586开发工具 jdk-8u121-windows-i586开发工具 jdk-8u121-windows-i586开发工具 jdk-8u121-windows-i586开发工具 jdk-8...

    JDK6.0+中文文档-lytim24.part1.rar

    java6.0文档chm版,分成三部分,分别为JDK6.0+中文文档-lytim24.part1.rar、JDK6.0+中文文档-lytim24.part2.rar、JDK6.0+中文文档-lytim24.part3.rar

    jdk-7u80-windows-x64安装包

    jdk-7u80-windows-x64安装包 jdk-7u80-windows-x64安装包 jdk-7u80-windows-x64安装包 jdk-7u80-windows-x64安装包 jdk-7u80-windows-x64安装包 jdk-7u80-windows-x64安装包 jdk-7u80-windows-x64安装包 jdk-7u80-...

    jdk-8u131-windows-x64

    jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-windows-x64jdk-8u131-...

    深入jdk6.0源码

    总而言之,《深入JDK6.0源码》是一个全面解析Java 6开发工具包的资源,它不仅包含Java语言的基本要素,还涵盖了从开发环境配置到高级特性的深入探讨,对于提升Java开发者的技术水平具有重要的指导价值。通过学习,...

    java-jdk1.8-8u361-all-jdk-win-linux

    java-jdk1.8-8u361-all-jdk-win-linux 该压缩包中包含jdk1.8-8u361下windows版本和linux版本,其包含快速安装包和对应的jdk压缩包版本,具体内容如下: jdk-8u361-linux-aarch64.rpm jdk-8u361-linux-i586.rpm jdk-8...

    官方JDK6.0中文版

    - 首先,从官方或可信渠道下载JDK 6.0的安装程序。 - 运行安装程序,按照提示完成安装过程。 - 配置环境变量,如JAVA_HOME指向JDK安装目录,PATH添加bin子目录,确保系统能够找到Java命令。 - 检验安装是否成功,...

    jdk-8u311-windows-x64.exe

    jdk-8u311-windows-x64.exe jdk-8u311-windows-x64.exe.zip jdk-8u311-windows-x64.exe jdk-8u311-windows-x64.exe.zip jdk-8u311-windows-x64.exe jdk-8u311-windows-x64.exe.zip jdk-8u311-windows-x64.exe jdk-8u...

    jdk8安装包: jdk-8u202-windows-x64

    1. 下载与操作系统匹配的JDK安装包,如"jdk-8u202-windows-x64.exe"。 2. 双击执行安装程序,按照向导指示进行操作,选择安装路径。 3. 在安装过程中,确保勾选"将Java添加到系统PATH"选项,以便在命令行中直接运行...

    JDK 6.0.zip

    8. **并发工具**:提供了一套新的并发工具类,如`ConcurrentHashMap`、`CyclicBarrier`和`Phaser`等,帮助开发者更好地编写多线程程序。 9. **性能优化**:JDK 6对JVM进行了大量的优化,包括垃圾回收、内存管理和...

    jdk-8u60-windows-i586-JDK1.8-32位

    jdk-8u60-windows-i586 jdk-8u60-windows-i586 jdk-8u60-windows-i586 jdk-8u60-windows-i586 jdk-8u60-windows-i586

Global site tag (gtag.js) - Google Analytics