码迷,mamicode.com
首页 > 编程语言 > 详细

线程池设计思路

时间:2018-12-29 11:11:02      阅读:193      评论:0      收藏:0      [点我收藏+]

标签:inf   并且   try   linked   generate   一个   string   import   panel   

 

线程池的思路和生产者消费者模型是很接近的。
1. 准备一个任务容器
2. 一次性启动10个 消费者线程
3. 刚开始任务容器是空的,所以线程都wait在上面。
4. 直到一个外部线程往这个任务容器中扔了一个“任务”,就会有一个消费者线程被唤醒notify
5. 这个消费者线程取出“任务”,并且执行这个任务,执行完毕后,继续等待下一次任务的到来。
6. 如果短时间内,有较多的任务加入,那么就会有多个线程被唤醒,去执行这些任务。

在整个过程中,都不需要创建新的线程,而是循环使用这些已经存在的线程
技术分享图片

 

 

 

package maptoxml;


import java.util.LinkedList;

public class ThreadPool {

// 线程池大小
int threadPoolSize;

// 任务容器
LinkedList<Runnable> tasks = new LinkedList<Runnable>();

// 试图消费任务的线程

public ThreadPool() {
threadPoolSize = 10;

// 启动10个任务消费者线程
synchronized (tasks) {
for (int i = 0; i < threadPoolSize; i++) {
new TaskConsumeThread("任务消费者线程 " + i).start();
}
}
}

public void add(Runnable r) {
synchronized (tasks) {
tasks.add(r);
// 唤醒等待的任务消费者线程
tasks.notifyAll();
}
}

class TaskConsumeThread extends Thread {
public TaskConsumeThread(String name) {
super(name);
}

Runnable task;

public void run() {
System.out.println("启动: " + this.getName());
while (true) {
synchronized (tasks) {
while (tasks.isEmpty()) {
try {
tasks.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
task = tasks.removeLast();
// 允许添加任务的线程可以继续添加任务
tasks.notifyAll();

}
System.out.println(this.getName() + " 获取到任务,并执行");
task.run();
}
}
}

}

 

 

 

 

 

 

 

 

 

 

package maptoxml;

public class TestThread {

public static void main(String[] args) {
ThreadPool pool = new ThreadPool();

for (int i = 0; i < 5; i++) {
Runnable task = new Runnable() {
@Override
public void run() {
//System.out.println("执行任务");
//任务可能是打印一句话
//可能是访问文件
//可能是做排序
}
};

pool.add(task);

try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

}

}

 

 

 

创造一个情景,每个任务执行的时间都是1秒
刚开始是间隔1秒钟向线程池中添加任务

然后间隔时间越来越短,执行任务的线程还没有来得及结束,新的任务又来了。
就会观察到线程池里的其他线程被唤醒来执行这些任务

 

package maptoxml;

public class TestThread {

public static void main(String[] args) {
ThreadPool pool = new ThreadPool();
int sleep = 1000;
for (int i = 0; i < 5; i++) {
Runnable task = new Runnable() {
@Override
public void run() {
//System.out.println("执行任务");
//任务可能是打印一句话
//可能是访问文件
//可能是做排序
}
};

pool.add(task);

try {
Thread.sleep(sleep);
sleep = sleep>100?sleep-100:sleep;
} catch (InterruptedException e) {
e.printStackTrace();
}
}

}

}

 

线程池设计思路

标签:inf   并且   try   linked   generate   一个   string   import   panel   

原文地址:https://www.cnblogs.com/chinaifae/p/10193774.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!