java 创建线程池的正确方式

  • 2022-03-21
  • 浏览 (1457)

一般创建线程池使用:

 ExecutorService executorService = Executors.newFixedThreadPool(10);

还有其它几种方式:
Executors 工厂方法Executors.newCachedThreadPool() 提供了无界线程池,可以进行自动线程回收;
Executors.newFixedThreadPool(int) 提供了固定大小线程池,内部使用无界队列;
Executors.newSingleThreadExecutor() 提供了单个后台线程。

这样的方式创建线程池很方便,当需要执行的线程数量大于设定的固定同时执行线程数量(10)的时候,多出的线程会在LinkedBlockingQueue()队列中等待,而此队列的默认最大储存数为Integer.MAX_VALUE,超过这个数量就会报OOM(java.lang.OutOfMemoryError)。

所以当你控制不了线程池中会被添加多少线程的时候,特别是在有可能存在大量线程的时候,我们就要用另外的方式创建线程,方式有很多,我说一种比较简单的,如下:

ExecutorService e = new ThreadPoolExecutor(10, 10, 60L, TimeUnit.SECONDS,new ArrayBlockingQueue(10));

没错,我们直接调用ThreadPoolExecutor类的构造函数,其实Executors方式创建线程也是调用此函数,所以我们只需要修改我们要调整的参数就可以了。

阿里也是推荐这种方式创建线程池的。

构造函数方法参数说明如下:

//corePoolSize:线程池的核心线程数;
//maximumPoolSize:线程池的最大线程数;
//keepAliveTime:线程池空闲时线程的存活时长;
//unit:线程存活时长大单位,结合上个参数使用;
//workQueue:存放任务的队列,使用的是阻塞队列;
new ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue) ;
0  赞