公告:欢迎访问,查看更多资源请点我^.^!            点我关闭广告
ThreadPoolExecutor构造参数分析
2019-06-27 16:18:19
412人阅读
评论(0)
分类:并发线程
package com.self;

import java.util.concurrent.*;

public class ThreadPoolExecutorDemo {

private LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<>(10);

/**
* 1. 当线程池小于corePoolSize时,新提交任务将创建一个新线程执行任务,即使此时线程池中存在空闲线程
* 2. 当线程池达到corePoolSize时,新提交任务将被放入workQueue中,等待线程池中任务调度执行
* 3. 当workQueue已满,且maximumPoolSize > corePoolSize时,新提交任务会创建新线程执行任务
* 4. 当提交任务数超过maximumPoolSize时,新提交任务由RejectedExecutionHandler处理
* 5. 当线程池中超过corePoolSize线程,空闲时间达到keepAliveTime时,关闭空闲线程
* 6. 当设置allowCoreThreadTimeOut(true)时,线程池中corePoolSize线程空闲时间达到keepAliveTime也将关闭
*/
private ThreadPoolExecutor executor =
new ThreadPoolExecutor(20, 100, 60, TimeUnit.SECONDS, queue,
Executors.defaultThreadFactory(), (r, executor) -> {
System.out.println(" sss " + executor.getActiveCount());
});

public static void main(String[] args) {
new ThreadPoolExecutorDemo().testThreadPoolExecutor();
}

void testThreadPoolExecutor() {
for (int i = 1; i <= 115; i++) { // 15 20 30 100 110 115
executor.submit(new MyRunner(i));
}
executor.shutdown();
}

class MyRunner implements Runnable {

private int num = -1;

public MyRunner(int num) {
this.num = num;
}

@Override
public void run() {
System.out.println("MyRunner num = " + num + " start queue.size=" + queue.size());
try {
TimeUnit.SECONDS.sleep(5L);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("MyRunner num = " + num + " end queue.size=" + queue.size());
}
}
}


分享一下:
赞一下(4)
博主资料
博主头像
zc521106
文章:34
浏览:19899
文章分类
Java(12)
NoSql(112)
数据库(12)
前端(12)
阅读排行
Java基础知识
(12)
NoSql应用
(112)
数据库Oracle语法
(12)
前端常用工具类
(12)
java web项目
(12)
linux安装mysql
(12)
评论区
这篇文章怎么样?写点评论吧!
姓名:
邮箱:
有回复时通知我:
发表
回复【10.20.30.32】:
暂无评论,快抢沙发!
* 以上用户言论只代表其个人观点,不代表iBlog网站的观点或立场,如有任何疑问请随时联系管理员...