线程池的创建多种方式

什么是线程池？

将多个线程放在一个容器内，当任务出现和结束时，只需要从线程池拿取和放入线程。避免线程的重复创建和销毁

优点：

• 提高资源利用率
• 提高响应速度
• 提高线程的管理

自定义线程池创建

ThreadPoolExecutor

• int corePoolSize,
• int maximumPoolSize,
• long keepAliveTime,
• TimeUnit unit,
• BlockingQueue<Runnable> workQueue,
• ThreadFactory threadFactory,
• RejectedExecutionHandler handler

各自参数的含义

int corePoolSize  核心线程数，线程中始终存活的线程数
int maximumPoolSize 最大线程数，线程池中允许的最大线程数，当线程池的任务队列满之后可以创建的最大线程数
long keepAliveTime 最大线程数可以存活的时间，当线程中没有任务执行时，最大线程就会销毁一部分，最终保持核心线程数量的线程
TimeUnit unit keepAliveTime的单位(TimeUnit.XXX)
BlockingQueue<Runnable> workQueue 阻塞队列，存储线程池等待执行的任务。
有以下几种队列类型：
ArrayBlockingQueue: 数组结构组成的有界阻塞队列
LinkedBlockingQueue：链表结构组成的有界阻塞队列
SynchronousQueue：不存储元素的阻塞队列，直接提交给线程不保存它们
PriorityBlockingQueue：支持优先级排序的无界阻塞队列
DelayQueue：使用优先级队列实现的无界阻塞队列，只有在延迟期满时才能从中提取元素
LinkedTransferQueue：由链表结构组成的无界阻塞队列。与SynchronousQueue类似，还含有非阻塞方法
LinkedBlockingDeque：由链表结构组成的双向阻塞队列
ThreadFactory threadFactory 线程工厂，主要用来创建线程
RejectedExecutionHandler handler 拒绝策略，拒绝处理任务时的策略
四种拒绝策略：
AbortPolicy：拒绝并抛出异常
CallerRunsPolicy：使用当前调用的线程来执行此任务
DiscardOldestPolicy:抛弃队列头部的任务（通常存活时间最长），并执行当前任务
DiscardPolicy:忽略并抛弃当前任务

固定线程池

创建一个固定大小的线程池，可控制并发的线程数，超出的线程会在队列中等待

---

ExecutorService executorService = Executors.newFixedThreadPool(5);

缓存线程池

创建一个可缓存的线程池，若线程数超过处理所需，缓存一段时间后会回收，若线程数不够，则新建线程

---

ExecutorService executorService = Executors.newCachedThreadPool();

单个线程池

创建单个线程数的线程池，它可以保证先进先出的执行顺序

---

ExecutorService executorService = Executors.newSingleThreadExecutor();

延迟执行线程池

创建一个可以执行延迟任务的线程池

---

ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);
        System.out.println("延迟执行前时间："+new Date());
        scheduledThreadPool.schedule(()->{
            System.out.println("延迟执行时间："+new Date());},5L, TimeUnit.SECONDS);

单线程延迟执行线程池

创建一个单线程的可以执行延迟任务的线程池

---

ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor();

抢占式执行线程池

创建一个抢占式执行的线程池（任务执行顺序不确定），注意此方法只有在 JDK 1.8+ 版本中才能使用

---

 ExecutorService executorService = Executors.newWorkStealingPool();
        for (int i = 0; i < 10; i++) {
            final int index = i;
            executorService.execute(()->{
                System.out.println(index+" 被执行，线程名:"+Thread.currentThread().getName());
            });

        }

        while (!executorService.isTerminated()){

        }