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.CallerRunPolicy() ); 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(){}) 