线程池的作用:
线程池作用就是限制系统中执行线程的数量。
根据系统的环境情况,可以自动或手动设置线程数量,达到运行的最佳效果;少了浪费了系统资源,多了造成系统拥挤效率不高。用线程池控制线程数量,其他线程排队等候。一个任务执行完毕,再从队列的中取最前面的任务开始执行。若队列中没有等待进程,线程池的这一资源处于等待。当一个新任务需要运行时,如果线程池中有等待的工作线程,就可以开始运行了;否则进入等待队列。
为什么要用线程池:
- 减少了创建和销毁线程的次数,每个工作线程都可以被重复利用,可执行多个任务
- 可以根据系统的承受能力,调整线程池中工作线线程的数目,防止因为因为消耗过多的内存,而把服务器累趴下(每个线程需要大约1MB内存,线程开的越多,消耗的内存也就越大,最后死机)
import java.util.LinkedList;
public class ThreadPool extends ThreadGroup{
private boolean isClosed = false; //线程池是否关闭
private LinkedList<Runnable> workQueue; //工作队列
private static int threadPoolID = 1; //线程池的id
public ThreadPool(int poolSize){ //poolSize 表示线程池中的工作线程的数量
super(threadPoolID+""); //指定ThreadGroup的名称
setDaemon(true); //继承到的方法,设置是否守护线程池
workQueue = new LinkedList<Runnable>(); //创建工作队列
for(int i=0;i< poolSize; i++){
new WorkThread(i).start(); //创建并启动工作线程,线程池数量是多少就创建多少个工作线程
}
}
public synchronized void execute(Runnable task){
if(isClosed){
throw new IllegalStateException();
}
if(task != null){
workQueue.add(task); //向队列中加入一个任务
notify(); //唤醒一个正在getTask()方法中待任务的工作线程
}
}
private synchronized Runnable getTask(int threadid) throws InterruptedException{
while(workQueue.size()==0){
if(isClosed)
return null;
System.out.println("工作线程"+ threadid + "等待任务...");
wait();
}
System.out.println("工作线程"+ threadid + "开始执行任务...");
return (Runnable) workQueue.removeFirst(); //返回队列中第一个元素,并从队列中删除
}
public synchronized void closePool(){
if(! isClosed){
waitFinish(); //等待工作线程执行完毕
isClosed = true;
workQueue.clear(); //清空工作队列
interrupt(); //中断线程池中的所有工作线程,此方法继承自ThreadGroup类
}
}
public void waitFinish(){
synchronized(this){
isClosed =true;
notifyAll(); //唤醒所有还在getTask()方法中等待任务的工作线程
}
Thread[] threads = new Thread[activeCount()]; //activeCount() 返回该线程组中活动线程的估计值。
int count = enumerate(threads); //enumerate()方法继承自ThreadGroup类,根据活动线程的估计值获得线程组中当前所有活动的工作线程
for(int i=0; i< count; i++){
try{
threads[i].join(); //等待工作线程结束
} catch(InterruptedException ex){
ex.printStackTrace();
}
}
}
private class WorkThread extends Thread{
private int id;
public WorkThread(int id){
//父类构造方法,将线程加入到当前的ThreadPool线程组中
super(ThreadPool.this, id+"");
this.id=id;
}
public void run(){
while(! isInterrupted()){ //isInterrupted() 方法继承自Thread类,判断线程是否被中断
Runnable task = null;
try{
task = getTask(id); //取出任务
}catch(InterruptedException ex){
ex.printStackTrace();
}
//如果getTask()返回Null或者线程执行getTask()时被中断,则结束此线程
if(task == null)
return;
try{
task.run(); //运行任务
} catch(Throwable t){
t.printStackTrace();
}
}
}
}
public static void main(String[] args) throws InterruptedException{
ThreadPool threadPool = new ThreadPool(3); //创建一个有3个工作线程的线程池
Thread.sleep(500); //休眠500毫秒,以便让线程池中的工作线程全部运行
//运行任务
for(int i=0; i<=5; i++){ //创建6个任务
threadPool.execute(createTask(i));
}
System.out.println("......................................");
threadPool.waitFinish(); //等待所有任务执行完毕
threadPool.closePool(); //关闭线程池
System.out.println("game over!");
}
private static Runnable createTask(final int taskID){
return new Runnable(){
public void run(){
try {
Thread.sleep(20);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(taskID + ": Hello");
}
};
}
}
相关推荐
NULL 博文链接:https://bijian1013.iteye.com/blog/2284676
java线程池实例java线程池实例E:\Users\Administrator\workspace
执行一个异步任务你还只是如下new Thread吗?是不是太low 了一点? 我这里有四种线程池的案例轻松让你理解和使用线程池。
线程池例子线程池例子线程池例子线程池例子
比较完整的线程池实例代码,Linux系统下完美运行
所以源代码都有 ,一个完整的线程池的实例
1.线程池管理器(ThreadPoolManager):用于创建并管理线程池 2.工作线程(WorkThread): 线程池中线程 3.任务接口(Task):每个任务必须实现的接口,以供工作线程调度任务的执行。 4.任务队列:用于存放没有处理的...
线程池详细讲解的很好实例!
简单实用的java线程池实例代码。包括测试代码和工程文件。
一个c++线程池类的使用。包含一个线程池类,工程使用vc6.0编译器,整个程序演示了怎么使用一个线程池。
1.9 实例:世界你好 1.11 入门级实例 :设计一个用户界面 1.12 入门级程序 :添加地址 1.13 入门实例:地址薄浏览程序 1.14 入门级实例:编辑与删除地址 1.15 入门级实例:地址薄查找功能 1.16 入门实例:从文件中...
delphi线程池mcpage实例
[1]中博主自己通过ThreadGroup实现一个线程池(挺方便理解的),使用的是jdk1.4版本,Jdk1.5版本以上提供了现成的线程池。 [2]中介绍了java.util.concurrent.Executors类的API。 [3]中介绍了Java中线程池的类体系...
在C#中可以通过System.Threading.ThreadPool类来实现,在默认情况下,ThreadPool最大可建立500个工作线程和1000个I/O线程(根据机器CPU个数和.net framework版本的不同,这些数据可能会有变化) ...
vc++多线程实例、线程池原理及实例相关资料汇总大全
JAVA100例之实例60 继承Thread实现多线程
delphi线程池的使用实例,带有详细的日志记录,方便初学者学习。
Windows下一个比较完美的线程池实现和示例 本线程池提供了如下功能: 1.能根据任务个数和当前线程的多少在最小/最大线程个数之间自动调整(Vista后的系统有 SetThreadpoolThreadMaximum 等函数有类似功能); 2.能方便...
自已用Qt写的线程池实现程序,可以正常运行,用socket进行通讯,很适合初学者学习借鉴;
ActiveMQ与Spring线程池整合的一个实例。 lib库没有上传。 对于实例的讲解,在竹子的论坛有我对这个实例的帖子(http://www.java2000.net/viewthread.jsp?tid=1167) lib中包含: apache-activemq-4.1.1.jar ...