学步园

线程池就好像...

一个工厂从外面接业务（任务）回来，而它养了一定数量的工人，工人主动去领取任务，然后负责这个任务的实施。

然而这个工厂怎么管理好业务和工人，怎么管理好任务的分配而不发生错误，即需要一个良好的机制了。

回到线程池，一样的道理。

有以下几个基本点：（这里针对简单基础的情况）

1. 用一个队列管理任务，任务包括创建时间、提交时间、执行时间、结束时间等描述任务执行过程的属性。（就好像一个工程项目做的施工计划或者合同计划类似属性）

2.用一个队列管理工作线程（工人），工作线程主动到线程任务队列中拿任务，如果队列为空则等待，直到有任务进来然后唤醒他们——有活干了！

3.有一个后台线程（监理）负责监控这些工作线程的工作状态，是空闲还是忙碌。

4.任务接口（或则抽象类），所有执行的任务必须符合标准。（就好像一个公司大部分只做相关业务的单子，除了......）

下面给出代码了，也是参考了网上的，进行了适当的调整，并且给出了适当的注释！

1.task接口。

package com.fox.threadPool;<br /> import java.util.Date;<br /> /**<br /> * @author huangfox<br /> * 抽象类<br /> * 任务的基类，所有任务必须继承这个类。<br /> * 任务的具体业务代码在core()方法中执行。<br /> */<br /> public abstract class Task implements Runnable {</p> <p> //任务创建时间<br /> private Date createT = null;<br /> //提交执行时间<br /> private Date submitT = null;<br /> //开始执行时间<br /> private Date runingT = null;<br /> //结束执行时间<br /> private Date finishT = null;<br /> //任务编号<br /> private int taskID ;</p> <p> //构造<br /> public Task(){<br /> this.createT = new Date();<br /> }</p> <p> @Override<br /> public void run() {<br /> core();<br /> }<br /> //核心业务代码，即任务的主要工作。<br /> public abstract void core();</p> <p> //任务详细信息<br /> public void display(){<br /> System.out.println("/t任务标示：" + this.taskID + "；/t创建时间：" + this.createT + "；/t提交时间：" + this.submitT + "；/t开始执行时间：" +<br /> this.runingT + "；/t结束执行的时间：" + this.finishT );<br /> }</p> <p> public Date getCreateT() {<br /> return createT;<br /> }<br /> public void setCreateT(Date createT) {<br /> this.createT = createT;<br /> }<br /> public Date getSubmitT() {<br /> return submitT;<br /> }<br /> public void setSubmitT(Date submitT) {<br /> this.submitT = submitT;<br /> }<br /> public Date getRuningT() {<br /> return runingT;<br /> }<br /> public void setRuningT(Date runingT) {<br /> this.runingT = runingT;<br /> }<br /> public Date getFinishT() {<br /> return finishT;<br /> }<br /> public void setFinishT(Date finishT) {<br /> this.finishT = finishT;<br /> }<br /> public int getTaskID() {<br /> return taskID;<br /> }<br /> public void setTaskID(int taskID) {<br /> this.taskID = taskID;<br /> }<br /> }<br />

2.worker——工作线程

package com.fox.threadPool;<br /> /**<br /> * @author huangfox<br /> * 驱动任务的线程类。<br /> * 由线程池统一管理。<br /> */<br /> public class Worker extends Thread {<br /> //是否可运行<br /> private boolean isRunning = true;<br /> //等待任务中（尚未驱动任务），当接收到任务并执行后isWating=false。<br /> private boolean isWaiting = true;<br /> //线程的标示<br /> private int id = -1;</p> <p> //构造<br /> public Worker(int id){<br /> this.id = id;<br /> start();<br /> }</p> <p> //停止当前线程<br /> public void Stop(){<br /> this.isRunning = false;<br /> }</p> <p> //获得isRunning的状态<br /> public boolean getIsRunning(){<br /> return this.isRunning;<br /> }</p> <p> //获得isWating的状态<br /> public boolean getIsWaiting(){<br /> return this.isWaiting;<br /> }<br /> @Override<br /> public void run() {<br /> //循环执行任务队列中的任务，前提是当前线程是可运行的，即isRunning=true<br /> while(isRunning){<br /> //声明一个任务<br /> Task task = null;<br /> //从任务队列中取出一个任务<br /> synchronized (ThreadPool.getTasks()) {<br /> //如果任务队列为空，则让任务队列等待一段时间再看看是否有任务可执行。<br /> while(ThreadPool.isTaskEmp()){<br /> try {<br /> ThreadPool.getTasks().wait(10);<br /> } catch (InterruptedException e) {<br /> e.printStackTrace();<br /> }<br /> }<br /> //当上面的循环执行结束，则说明任务队列不为空<br /> //取出第一个任务进行执行<br /> task = ThreadPool.getTasks().remove(0);<br /> }<br /> if( task != null ){<br /> //当任务为可执行任务时（not null），则这个线程有任务要处理了，则他的状态就不是闲置了。<br /> this.isWaiting = false;<br /> //执行任务<br /> task.run();<br /> }<br /> //任务执行结束<br /> //重新置回当前线程的状态为闲置<br /> this.isWaiting = true;<br /> ThreadPool.getTasks().remove(task);<br /> task = null ;<br /> }// end synchronized<br /> }</p> <p>}<br />

3.ThreadPool——线程池

package com.fox.threadPool;<br /> import java.util.ArrayList;<br /> import java.util.Collections;<br /> import java.util.Date;<br /> import java.util.List;<br /> /**<br /> * @author huangfox<br /> * 线程池，线程管理类<br /> */<br /> public class ThreadPool {<br /> //线程池实例<br /> private static ThreadPool pool = ThreadPool.getInstance();<br /> //线程池中线程数量<br /> private int MAX_THREAD_COUNT = 10;<br /> //线程数组<br /> private static Worker[] workers ;<br /> //任务队列<br /> private static List<Task> tasks = Collections.synchronizedList(new ArrayList<Task>());<br /> //任务标示<br /> private static int taskid = 0;</p> <p> //<br /> public static List<Task> getTasks() {<br /> return tasks;<br /> }<br /> //单例<br /> public static synchronized ThreadPool getInstance(){<br /> if(pool == null){<br /> return new ThreadPool();<br /> }else{<br /> return pool;<br /> }<br /> } </p> <p> //构造<br /> private ThreadPool(){<br /> this.workers = new Worker[MAX_THREAD_COUNT];<br /> for (int i = 0; i < this.workers.length; i++) {<br /> this.workers[i] = new Worker(i);<br /> }<br /> }</p> <p> //构造（重载）<br /> // private ThreadPool(int maxThreadCount){<br /> // this.MAX_THREAD_COUNT = maxThreadCount;<br /> // this.workers = new Worker[maxThreadCount];<br /> // for (int i = 0; i < maxThreadCount; i++) {<br /> // this.workers[i] = new Worker(i);<br /> // }<br /> // }</p> <p> //销毁线程池<br /> public synchronized void destory(){<br /> for (int i = 0; i < this.workers.length; i++) {<br /> //这里不是线程的stop方法。<br /> this.workers[i].Stop();<br /> //清除线程<br /> this.workers[i] = null;<br /> }<br /> //清除任务队列。<br /> this.tasks.clear();<br /> }</p> <p> //获得任务队列是否为空<br /> public static boolean isTaskEmp(){<br /> return tasks.isEmpty();<br /> }</p> <p> //获得当前线程池的情况<br /> public void display(){<br /> System.out.println("线程池情况：");<br /> for (int i = 0; i < this.workers.length; i++) {<br /> System.out.println("/t"+this.workers[i].getId() + "/t" + (this.workers[i].getIsWaiting()==true?"闲置":"工作"));<br /> }<br /> }</p> <p> //添加单个任务<br /> public void addTask(Task newTask){<br /> synchronized (this.tasks) {<br /> //设定任务标示<br /> newTask.setTaskID(++this.taskid);<br /> //设定任务提交时间<br /> newTask.setSubmitT(new Date());<br /> //将任务加入到任务队列当中<br /> this.tasks.add(newTask);<br /> // System.out.print("添加任务：" );<br /> // newTask.display();<br /> //唤醒任务队列，因为在线程取任务的时候若任务队列为空则会将tasks.wait();<br /> //这里需要唤醒。<br /> this.tasks.notifyAll();</p> <p> }<br /> }<br /> }</p> <p>

4.monitor——监控类

package com.fox.threadPool;<br /> /**<br /> * @author huangfox<br /> *<br /> */<br /> public class Monitor extends Thread {<br /> ThreadPool pool = null ; </p> <p> public Monitor(ThreadPool p){<br /> this.pool = p ;<br /> }</p> <p> @Override<br /> public void run() {<br /> while(true){<br /> pool.display();<br /> try {<br /> Thread.sleep(1000);<br /> } catch (InterruptedException e) {<br /> // TODO Auto-generated catch block<br /> e.printStackTrace();<br /> }<br /> }<br /> }</p> <p>}<br />

5.以下是配合测试的，具体的任务TaskTest

package com.fox.threadPool;</p> <p>/**<br /> * @author huangfox<br /> * 简单实现一个任务类。<br /> */<br /> public class TaskTest extends Task {<br /> @Override<br /> public void core() {<br /> System.out.println("任务【" + super.getTaskID() + "】开始...");<br /> try {<br /> //模拟具体业务运行时间<br /> Thread.sleep(2000);<br /> } catch (InterruptedException e) {<br /> e.printStackTrace();<br /> }<br /> System.out.println("任务【" + super.getTaskID() + "】结束...");<br /> }<br /> }<br />

6.测试主程序

package com.fox.threadPool;<br /> public class MainApp {<br /> /**<br /> * @param args<br /> */<br /> public static void main(String[] args) {<br /> ThreadPool pool = ThreadPool.getInstance();<br /> //<br /> Monitor m = new Monitor(pool);<br /> m.setDaemon(true);<br /> m.start();<br /> for (int i = 0; i < 10; i++) {<br /> pool.addTask(new TaskTest());<br /> try {<br /> //控制添加任务的速度。<br /> Thread.sleep(150);<br /> } catch (InterruptedException e) {<br /> e.printStackTrace();<br /> }<br /> }<br /> }<br /> }<br />

虽然是入门级的线程池，但是基本的原理还是比较清晰地。