线程池常见创建方式


public class fixThread {
public static void main(String[] args) {
ExecutorService executorService = Executors.newFixedThreadPool(5);//设置线程初始容量为5

for (int i = 0; i < 10; i++) {
executorService.execute(() -> {
System.out.println(Thread.currentThread().getName() + "正在执行中");
});
}


}
}

2.newCachedThreadPool（可缓存线程池）

创建一个可缓存线程池，它的特点是根据需求创线程数，不需要指定数量

代码如下（示例）：

//可缓存线程池
public class CacheThread {
public static void main(String[] args) {

ExecutorService executorService = Executors.newCachedThreadPool();
for (int i = 0; i <10 ; i++) {
executorService.execute(()->{
System.out.println(Thread.currentThread().getName()+"正在执行中");
});
}

}
}

3.newSingleThreadExecutor（一池一线程）

创建一个线程的线程池，不需要指定数量

public class fixThread {
    public static void main(String[] args) {

        ExecutorService executorService = Executors.newSingleThreadExecutor();
        for (int i = 0; i <10 ; i++) {
             executorService.execute(()->{
                 System.out.println(Thread.currentThread().getName()+"正在执行中");
             });
        }

    }
}

4.newScheduledThreadPool(任务线程池)

public class fixThread {
public static void main(String[] args) {

ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(5);

for (int i = 0; i <10 ; i++) {
scheduledExecutorService.schedule(()->{
System.out.println(Thread.currentThread().getName()+"正在执行延迟任务");
},5, TimeUnit.SECONDS);
}

}

三、自定义线程池ThreadPoolExecutor

七大参数：

1，int corePoolSize, //核心线程数，线程池一直存在的线程数
2，int maximumPoolSize, //最大线程数，超过核心线程池另外运行存在的线程数
3，long keepAliveTime, //存活时间，最大线程数的不被使用的存活时间
4，TimeUnit unit,//存活单位
5，BlockingQueue<Runnable> workQueue) //工作队列
6，Executors.defaultThreadFactory()//线程工厂

7，defaultHandler 拒绝策略任务超过线程可以处理的任务时候，采取的处理方式

public class fixThread {
public static void main(String[] args) {

ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5,10,5,TimeUnit.SECONDS,new ArrayBlockingQueue<>(5,true),Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());
for (int i = 0; i <12 ; i++) {
threadPoolExecutor.execute(()->{
System.out.println(Thread.currentThread().getName()+"执行中");
});
}

}
}

ThreadPoolExecutor 相比于其他创建线程池的优势在于，它可以通过参数来控制最大任务数和拒绝策略，让线程池的执行更加透明和可控，所以在阿里巴巴《Java开发手册》是这样规定的：

【强制要求】线程池不允许使用 Executors 去创建，而是通过 ThreadPoolExecutor 的方式，这样的处理方式让写的同学更加明确线程池的运行规则，规避资源耗尽的风险。

说明：Executors 返回的线程池对象的弊端如下：
1） FixedThreadPool 和 SingleThreadPool：允许的请求队列长度为 Integer.MAX_VALUE，可能会堆积大量的请求，从而导致 OOM。
2）CachedThreadPool：允许的创建线程数量为 Integer.MAX_VALUE，可能会创建大量的线程，从而导致 OOM。