100行Java代码构建一个线程池 - 编程入门网

最后一个类是SimpleThread类，它是Thread类的一个子类，它才真正对客户端的请求进行处理，SimpleThread在示例程序初始化时都处于睡眠状态，但如果它接受到了ThreadPoolManager类发过来的调度信息，则会将自己唤醒，并对请求进行处理。

首先我们来看一下TestThreadPool类的源码：

//TestThreadPool.java1 import java.io.*;234 public class TestThreadPool5 {6 public static void main(String[] args)7 {8 try{9 BufferedReader br = new BufferedReader(new InputStreamReader(System.in));10 String s;11 ThreadPoolManager manager = new ThreadPoolManager(10);12 while((s = br.readLine()) != null)13 {14 manager.process(s);15 }16 }catch(IOException e){}17 }18 }

100行Java代码构建一个线程池(2)

由于此测试程序用到了输入输入类，因此第1行导入了JAVA的基本IO处理包，在第11行中，我们创建了一个名为manager的类，它给ThreadPoolManager类的构造函数传递了一个值为10的参数，告诉ThreadPoolManager类：我要一个有10个线程的池，给我创建一个吧！第12行至15行是一个无限循环，它用来等待用户的键入，并将键入的字符串保存在s变量中，并调用ThreadPoolManager类的process方法来将这个请求进行处理。 下面我们再进一步跟踪到ThreadPoolManager类中去，以下是它的源代码：

//ThreadPoolManager.java1 import java.util.*;234 class ThreadPoolManager5 {67 private int maxThread;8 public Vector vector;9 public void setMaxThread(int threadCount)10 {11 maxThread = threadCount;12 }1314 public ThreadPoolManager(int threadCount)15 {16 setMaxThread(threadCount);17 System.out.println("Starting thread pool...");18 vector = new Vector();19 for(int i = 1; i <= 10; i++)20 {21 SimpleThread thread = new SimpleThread(i);22 vector.addElement(thread);23 thread.start();24 }25 }2627 public void process(String argument)28 {29 int i;30 for(i = 0; i < vector.size(); i++)31 {32 SimpleThread currentThread = (SimpleThread)vector.elementAt(i);33 if(!currentThread.isRunning())34 {35 System.out.println("Thread "+ (i+1) +" is processing:" +argument);36 currentThread.setArgument(argument);37 currentThread.setRunning(true);38 return;39 }40 }41 if(i == vector.size())42 {43 System.out.println("pool is full, try in another time.");44 }45 }46 }//end of class ThreadPoolManager

100行Java代码构建一个线程池(3)

我们先关注一下这个类的构造函数，然后再看它的process()方法。第16－24行是它的构造函数，首先它给ThreadPoolManager类的成员变量maxThread赋值，maxThread表示用于控制线程池中最大线程的数量。第18行初始化一个数组vector，它用来存放所有的SimpleThread类，这时候就充分体现了JAVA语言的优越性与艺术性：如果你用C语言的话，至少要写100行以上的代码来完成vector的功能，而且C语言数组只能容纳类型统一的基本数据类型，无法容纳对象。好了，闲话少说，第19－24行的循环完成这样一个功能：先创建一个新的SimpleThread类，然后将它放入vector中去，最后用thread.start()来启动这个线程，为什么要用start()方法来启动线程呢？因为这是JAVA语言中所规定的，如果你不用的话，那这些线程将永远得不到激活，从而导致本示例程序根本无法运行。 下面我们再来看一下process()方法，第30－40行的循环依次从vecto

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!