线程池-Executors提供4个线程池

Posted 2020-12-02 smilingeye

 

1.为什么不使用Executors提供4个线程池创建线程池

阿里巴巴开放手册这样写：

4. 【强制】线程池不允许使用 Executors 去创建，而是通过 ThreadPoolExecutor 的方式，这样 的处理方式让写的同学更加明确线程池的运行规则，规避资源耗尽的风险。 
说明：Executors 返回的线程池对象的弊端如下： 
1）FixedThreadPool 和 SingleThreadPool:   允许的请求队列长度为 Integer.MAX_VALUE，可能会堆积大量的请求，从而导致 OOM。 
2）CachedThreadPool 和 ScheduledThreadPool:   允许的创建线程数量为 Integer.MAX_VALUE，可能会创建大量的线程，从而导致 OOM。 

2.创建过程

虽然不建议使用Executors创建线程池，但是还是要搞清楚他的原理。

public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                                      0L, TimeUnit.MILLISECONDS,
                                      new LinkedBlockingQueue<Runnable>());
    }

public static ExecutorService newSingleThreadExecutor() {
        return new FinalizableDelegatedExecutorService
            (new ThreadPoolExecutor(1, 1,
                                    0L, TimeUnit.MILLISECONDS,
                                    new LinkedBlockingQueue<Runnable>()));
    }

注意：

　　1.核心线程池=最大线程池（不聘请临时工）

　　2.LinkedBlockingQueue按照先进先出队列，最大队列为Integer.MAX_VALUE

public static ExecutorService newCachedThreadPool() {
        return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                      60L, TimeUnit.SECONDS,
                                      new SynchronousQueue<Runnable>());
    }

注意：

　　1.没有核心线程池，只有最大线程池（全部聘请临时工干活，干完活就全部辞退，不地道）

　　2.最大线程池Integer.MAX_VALUE

　　3.SynchronousQueue是这样一种阻塞队列，其中每个 put 必须等待一个 take，即如果有两个线程等待take，队列可以存两个，如果没有等待take，队列不能存入。

public ScheduledThreadPoolExecutor(int corePoolSize) {
        super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
              new DelayedWorkQueue());
    }

注意：

　　1.最大线程池Integer.MAX_VALUE

　　2.这个线程池还不太理解，延后