//线程池: 只是按初始线程数执行任务,并没有创建新的工作者线程(take给阻塞了,影响吞吐量)
public class ThreadPool {
//任务队列
private BlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>();
private int poolSize; //初始线程数
private int maxPoolSize; //最大线程数
private int size = 0; //线程数
//运行线程数:工作者
private List<Worker> works = new ArrayList<Worker>();
private boolean isshutdown = false; //线程池状态
private Timer timer;
public ThreadPool(int poolSize,int maxPoolSize) {
this.poolSize = poolSize;
this.maxPoolSize = maxPoolSize;
init();
}
//初始化一些工作者
private void init() {
Worker w = null;
for(int i=0;i<this.poolSize;i++) {
w = createThread();
works.add(w);
}
}
//创建工作者
private Worker createThread() {
Worker w = new Worker();
Thread t = new Thread(w);
t.setName("t" + size);
w.thread = t;
t.start();
size++;
return w;
}
private Worker createThread(Runnable task) {
Worker w = new Worker(task);
Thread t = new Thread(w);
t.setName("t" + size);
w.thread = t;
t.start();
size++;
return w;
}
//提交任务
public void execute(Runnable task) {
System.out.println("execute..");
try {
if(size <= poolSize) { //放入队列
queue.offer(task, 10, TimeUnit.SECONDS);
}else if(size<maxPoolSize) { //在新创建的线程中执行任务
Worker w = createThread();
works.add(w);
}else { //拒绝任务
reject(task);
}
} catch (InterruptedException e) {
e.printStackTrace();
} catch(Exception e) {
e.printStackTrace();
}
}
//拒绝任务
private void reject(Runnable task) throws Exception{
throw new Exception("无法提交");
}
//获取任务
public Runnable getTask() {
// if(!queue.isEmpty()) {
try {
return queue.take();
} catch (InterruptedException e) {
e.printStackTrace();
}
// }
//没有任务,工作者线程自动终止
return null;
}
public void shutdown() {
this.isshutdown = true;
//终止工作者线程
//使用定时器检测线程池的任是否全部执行完,如果执行完就终止线程
timer = new Timer();
timer.schedule(new TimerTaskImpl(), 30*1000);
}
private class Worker implements Runnable{
private Runnable firstTask;
private Thread thread;
public Worker() {
}
public Worker(Runnable task) {
System.out.println("创建新的工作者线程..");
this.firstTask = task;
}
public void run() {
System.out.println("worker ..");
Runnable task = null;
if(firstTask != null) {
task = firstTask;
firstTask = null;
}
while(task!=null || (task=getTask())!=null) {
task.run();
System.out.println(thread.getName());
task = null;
}
}
//终止线程
public void interrupt() {
if(Thread.currentThread()!=thread) {
thread.interrupt();
}
}
}
//任务
static class Task implements Runnable{
static int i = 0;
public void run() {
System.out.println((i++) + " hello");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
//定时任务:关闭工作者线程
class TimerTaskImpl extends TimerTask{
public void run() {
if(isshutdown && queue.isEmpty()) {
for(Worker w: works) {
w.interrupt();
}
timer.cancel();
}
System.out.println("定时器任务..");
}
}
public static void main(String[] args) {
// ThreadPool pool = new ThreadPool(1,2);
// for(int i=0;i<2;i++) {
// Task task = new Task();
// pool.execute(task);
// }
ThreadPool pool = new ThreadPool(3,10);
for(int i=0;i<20;i++) {
Task task = new Task();
pool.execute(task);
}
pool.shutdown();
}
}
相关推荐
线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池线程池...
corePoolSize:核心池的大小,在创建了线程池后,线程池中的线程数为0,当有任务来之后,就会创建一个线程去执行任务,当线程池中的线程数目达到corePoolSize后,就会把到达的任务放到缓存队列当中; ...
阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池...
一、线程池 1、为什么需要使用线程池 1.1 创建/销毁线程伴随着系统开销,过于频繁的创建/销毁线程,会很大程度上影响处理效率。 记创建线程消耗时间T1,执行任务消耗时间T2,销毁线程消耗时间T3,如果T1+T3>T2,那...
VC实现线程池
易语言简易线程池的实现。 ——V雪落有声V原创。转载请保留。前文:。为了能充分理解本篇文章的内容,需要了解的知识如下:。1.事件对象的使用:http://baike.baidu.com/view/751499.htm。2.信号量的使用:...
简单的线程池程序+中文文档 包结构: com.tangkai.threadpool --SimpleThread.java 工作线程 --TestThreadPool.java 程序入口 --ThreadPoolManager.java 线程池管理类
Windows下一个比较完美的线程池实现和示例 本线程池提供了如下功能: 1.能根据任务个数和当前线程的多少在最小/最大线程个数之间自动调整(Vista后的系统有 SetThreadpoolThreadMaximum 等函数有类似功能); 2.能方便...
C#管理线程池的类 /* How to use Thread Classs * * ============== * public ELMService() { InitializeComponent(); etm.ClalThreadPool("EmailThreads", (uint)ApplicationInfo.EmailParsingThreads); ...
线程池
因为本人是个小白,多线程经常用,但是线程池并没有用过,(一听到线程池,总感觉高大上)。但是近期写彩票软件的时候发现,多线程长期操作会导致内容不断的升高直至报错,遂想起了线程池,完善后发现不是一般的叼...
2.然后根据提示运行java命令执行示例程序,观看线程池的运行结果 目标:Java中多线程技术是一个难点,但是也是一个核心技术。因为Java本身就是一个多线程语言。本人目前在给46班讲授Swing的网络编程--使用Swing来...
1.线程池管理器(ThreadPoolManager):用于创建并管理线程池 2.工作线程(WorkThread): 线程池中线程 3.任务接口(Task):每个任务必须实现的接口,以供工作线程调度任务的执行。 4.任务队列:用于存放没有处理的...
以下示例显示如何使用线程池。首先创建 ManualResetEvent 对象,此对象使程序能够知道线程池何时运行完所有的工作项。接着,尝试向线程池添加一个线程。如果添加成功,则添加其余的线程(本例中为 4 个)。然后...
linux线程池创建c实现 linux线程池创建c实现 linux线程池创建c实现 linux线程池创建c实现 linux线程池创建c实现 linux线程池创建c实现
使用Windows自带的线程池功能,比你写的线程池性能好得多
什么是线程池?简单点说,线程池就是有一堆已经创建好了的线程,初始它们都处于空闲等待状态,当有新的任务需要处理的时候,就从这个池子里面取一个空闲等待的线程来处理该任务,当处理完成了就再次把该线程放回池中...
这是一个简单线程池的实现,虽然有很多bug,但是能够简单地实现线程池。
Java开发,Android开发,自己实现线程池,明白线程池的实现机制
本实例采用c3p0作为线程池工具包,讲解了jdbc基本用法,同时给出了Oracle以及mysql增(单插入、批量插入)、删、查、改等功能,可以直接复制使用。