private static ThreadPoolExecutor getThreadPoolExecutor() {
int corePoolSize=10;
int maximumPoolSize=10;
long keepAliveTime=1000L;
BlockingQueue<Runnable> workQueue=new LinkedBlockingDeque<>(100);
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
corePoolSize,
maximumPoolSize,
keepAliveTime,
TimeUnit.MILLISECONDS,
workQueue,
new ThreadPoolExecutor.CallerRunsPolicy()
);
return threadPoolExecutor;
}
如下种写法常用吗,判断 ActiveCount 来提交线程
#1
int canCreateThreads = threadPool.getCorePoolSize()- threadPool.getActiveCount();
log.info(" 支持核心线程数 : {} 个, 已激活 {} 个线程, 还可创建线程数 : {} 个", threadPool.getCorePoolSize(), threadPool.getActiveCount(),canCreateThreads);
if (canCreateThreads > 0) {
executor .execute(new Runnable(){})
}
之前工作中一直使用这种简单的方式,有任务时,直接提交线程池,具体怎么执行根据线程池配置来。
#2
executor.execute(new Runnable(){})