线程池的理解

妖狐艹你老母 2023-07-15 05:56 35阅读 0赞

1.  为什么使用线程池，有什么优势呢？  
    线程池的主要工作是控制线程的数量，处理过程中将任务放入队列，然后在线程创建启动这些任务，如果线程数量超过了最大数量，超出数量的线程排队等候，等其他线程执行完毕，在从队列中取出任务来执行。它的主要特点是*线程复用*，*控制最大并发数*，*管理线程*。  
    它通过重复利用已创建的线程降低线程创建和销毁造成的资源消耗；提高了响应速度，当任务到达时，不需要等待线程创建就能立即执行；提高线程的可管理性，如果无限制的创建线程，不仅会造成消耗系统资源，还会降低系统的稳定性，使用线程池可以进行统一的分配，调优和监控。
2.  编码实现  
    在java的API中通过Executors工具类可创建FixedThreadPool、SingleThreadPool、CacheThreadPool、ScheduledThreadPool、WorkStealingPool等常见线程池，不过它们底层实现都是ThreadPoolExecutor，在阿里巴巴开发手册中也强调说明：线程池不允许使用 Executors 去创建，而是通过 ThreadPoolExecutor 的方式，这样  
    的处理方式让写的同学更加明确线程池的运行规则，规避资源耗尽的风险。
3.  Executors 返回的线程池对象的弊端  
    1） FixedThreadPool 和 SingleThreadPool :  
    允许的请求队列长度为 Integer.MAX\_VALUE ，可能会堆积大量的请求，从而导致 OOM 。

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

2） CachedThreadPool 和 ScheduledThreadPool :  
允许的创建线程数量为 Integer.MAX\_VALUE ，可能会创建大量的线程，从而导致 OOM 。

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