线程池介绍

迈不过友情╰ 2022-02-28 10:46 279阅读 0赞

##### 创建线程池的方法 #####

1、使用JDK1.5自带的Executors框架创建线程池。  
Executors框架提供了4种线程池的创建方法

*  创建一个固定数量的线程池

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

特点：  
1、线程池的核心线程数和最大线程数都是初始创建时传入的线程数，  
2、空闲线程结束的超时时间为0  
3、使用的LinkedBlockingQueue阻塞队列，该阻塞队列是链  
表结构的无解队列

*  创建单个线程的线程池

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

特点：  
1、核心线程和最大线程都是1,  
2、空闲线程结束的超时时间为0  
3、使用的也是LinkedBlockingQueue阻塞队列

*  创建缓存线程池

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

特点：  
1、核心线程数为0  
2、线程池最大线程为Integer.MAX\_VALUE  
3、空闲线程结束超时时间为60s  
4、使用的是SynchronousQueue阻塞队列,该阻塞队列不会存储元素

*  创建定时线程池

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

该线程池的特点创建一个可定时执行任务的线程池

#### Executors框架分析 ####

1、Executors框架提供的集中创建线程池的方法，底层实际上都是使用了如下构造方法

public ThreadPoolExecutor(int corePoolSize,
                                  int maximumPoolSize,
                                  long keepAliveTime,
                                  TimeUnit unit,
                                  BlockingQueue<Runnable> workQueue) {
            this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
                 Executors.defaultThreadFactory(), defaultHandler);
        }

参数介绍：  
corePoolSize：核心线程的数量，线程池在创建之后会一直存在的线程数量  
maximimPoolSize：线程池的最大线程数  
keepAliveTime:空闲线程的超时时间(当一个线程处于空闲状态时，空闲多久会被停止)  
unit：空闲时间的时间单位  
workQueue：阻塞队列  
handler：决绝策略(如果线程已经达到最大且阻塞队列也已经满了，线程池要执行的处理策略)

2、运行分析

*  如果当前线程池中的线程数量没有达到corePoolSize，则有新的任务直接创建新的线程执行
 *  如果当前线程数量超过了corePoolSize，但是队列没有满，则直接将任务放入阻塞队列
 *  如果当前线程数量达到了核心线程数且阻塞队列也满了，但是没有达到最大线程数量，则继续创建新的线程执行任务
 *  如果当前线程已经达到线程池最大线程数量，则执行拒绝策略

3、常用的阻塞队列的介绍

*  LinkedBlockingQueue：是一个基于链表的无界阻塞队列，队列大小为Integer.MAX\_VALUE
 *  ArrayBlockingQueue：数组结构的有界队列
 *  PriorityBlockingQueue：有优先级的阻塞队列
 *  SynchronousQueue：不会存储元素的阻塞队列
 *  DelayedWorkQueue:一个无界队列，能按照一定的顺序对队列中的元素进行排序

4、拒绝策略

*  Executors框架提供的创建线程池的方法，使用的默认的拒绝策略

private static final RejectedExecutionHandler defaultHandler =
            new AbortPolicy();

AbortPolicy：如果创建线程池不传拒绝策略，则默认使用该策略。  
该策略表示当线程池队列满了且达到最大线程时，直接拒绝处理，抛出异常，让调用者自行处理  
DiscardPolicy：丢弃策略，线程池不做任何处理  
DiscardOldestPolicy：丢弃旧的任务来执行新的任务  
CallerRunsPolicy：既不抛弃新任务，也不抛弃旧任务，直接在当前的线程运行新的任务。当前线程一般都是主线程  
 **如果需要自定义拒绝策略，可以实现RejectedExecutionHandler接口**

5、创建线程的工厂  
每当线程池需要创建一个线程时，都是通过线程工厂来创建的，如果没有指定线程工厂，就回使用默认的defaultThreadFactor  
通过看DefaultThreadFactory()类源码，该类实现了ThreadFactory接口，所以，如果有需要定制线程工厂，**实现ThreadFactory接口即可**

6、阻塞队列的方法  
![在这里插入图片描述][20190325171305929.gif]

[20190325171305929.gif]: /images/20220228/85cfff82d2744ba79d17dadf92cc5e71.png