Java中高效创建与管理线程池的方法与实践

线程池的作用:

     线程池作用就是限制系统中执行线程的数量。
     根据系统的环境情况&＃xff0c;可以自动或手动设置线程数量&＃xff0c;达到运行的最佳效果&＃xff1b;少了浪费了系统资源&＃xff0c;多了造成系统拥挤效率不高。用线程池控制线程数量&＃xff0c;其他线程排队等候。一个任务执行完毕&＃xff0c;再从队列的中取最前面的任务开始执行。若队列中没有等待进程&＃xff0c;线程池的这一资源处于等待。当一个新任务需要运行时&＃xff0c;如果线程池中有等待的工作线程&＃xff0c;就可以开始运行了&＃xff1b;否则进入等待队列。

为什么要用线程池:

1. 减少了创建和销毁线程的次数&＃xff0c;每个工作线程都可以被重复利用&＃xff0c;可执行多个任务
2. 可以根据系统的承受能力&＃xff0c;调整线程池中工作线线程的数目&＃xff0c;防止因为因为消耗过多的内存&＃xff0c;而把服务器累趴下(每个线程需要大约1MB内存&＃xff0c;线程开的越多&＃xff0c;消耗的内存也就越大&＃xff0c;最后死机)

线程池类

import java.util.LinkedList; /** * &＃64;project LocationGateway * &＃64;author sunnylocus * &＃64;verson 1.0.0 * &＃64;date Aug 2, 2008 * &＃64;jdk 1.4.2 */
public class ThreadPool extends ThreadGroup { private boolean isClosed &＃61; false; //线程池是否关闭 private LinkedList workQueue; //工作队列 private static int threadPoolID &＃61; 1; //线程池的id public ThreadPool(int poolSize) { //poolSize 表示线程池中的工作线程的数量 super(threadPoolID &＃43; ""); //指定ThreadGroup的名称 setDaemon(true); //继承到的方法&＃xff0c;设置是否守护线程池 workQueue &＃61; new LinkedList(); //创建工作队列 for(int i &＃61; 0; i }


2.测试类

import com.tdt.impl.ls.ThreadPool; public class ThreadPoolTest { public static void main(String[] args) throws InterruptedException { ThreadPool threadPool &＃61; new ThreadPool(3); //创建一个有个3工作线程的线程池 Thread.sleep(500); //休眠500毫秒,以便让线程池中的工作线程全部运行 //运行任务 for (int i &＃61; 0; i <&＃61;5 ; i&＃43;&＃43;) { //创建6个任务 threadPool.execute(createTask(i)); } threadPool.waitFinish(); //等待所有任务执行完毕 threadPool.closePool(); //关闭线程池 } private static Runnable createTask(final int taskID) { return new Runnable() { public void run() { // System.out.println("Task" &＃43; taskID &＃43; "开始"); System.out.println("Hello world"); // System.out.println("Task" &＃43; taskID &＃43; "结束"); } }; }
}


结果:

工作线程0等待任务...
工作线程1等待任务...
工作线程2等待任务... 工作线程0开始执行任务...
Hello world
工作线程0等待任务... 工作线程1开始执行任务...
Hello world
工作线程1等待任务... 工作线程2开始执行任务...
Hello world
工作线程2等待任务... 工作线程0开始执行任务...
Hello world
工作线程0等待任务... 工作线程1开始执行任务...
Hello world
工作线程1等待任务... 工作线程2开始执行任务...
Hello world
工作线程2等待任务...