线程池

朱雀 2022-01-07 09:37 117阅读 0赞

## 四种线程池 ##

Executors有四个线程池，  
单一线程池，newSingleThreadExecutor  
固定线程池，newFixedThreadPool  
缓冲线程池，newCachedThreadPool  
周期线程池，newScheduledThreadPool

ThreadPoolExecutor参数有核心线程数，最大线程数，线程空闲时间，时间单位，阻塞队列，线程工厂，拒绝策略  
四种拒绝策略  
AbortPolicy，中止策略，默认策略，抛出异常  
DiscardPolicy，丢弃策略，和中止类似，丢弃任务，但是不抛出异常  
DiscardOldestPolicy，丢弃最旧策略，丢弃最旧的任务  
CallerRunsPolicy，调用者运行策略，当前线程执行任务

## 线程池的关闭方式有几种，各自的区别是什么 ##

两种关闭方式  
shutdown:  
调用之后不允许继续往线程池内继续添加线程;  
线程池的状态变为SHUTDOWN状态;  
所有在调用shutdown()方法之前提交到ExecutorSrvice的任务都会执行;  
一旦所有线程结束执行当前任务，ExecutorService才会真正关闭。

shutdownNow():  
该方法返回尚未执行的 task 的 List;  
线程池的状态变为STOP状态;  
阻止所有正在等待启动的任务, 并且停止当前正在执行的任务;

简单点来说，就是: shutdown()调用后，不可以再 submit 新的 task，已经 submit 的将继续执行 shutdownNow()调用后，试图停止当前正在执行的 task，并返回尚未执行的 task 的 list

## ThreadPoolExecutor ##

线程池初始化时，线程数为0，需要的时候创建核心线程，之后空闲了就保留，不会释放空闲线程。  
核心线程用完了，加入阻塞队列；阻塞队列满了，创建最大线程；阻塞队列满了，启用拒绝策略。  
最大线程空闲了，会释放。

举例

public static void main(String[] args) throws InterruptedException {
            ThreadPoolExecutor pool = new ThreadPoolExecutor(5, 10,
                    0L, TimeUnit.MILLISECONDS,
                    new LinkedBlockingQueue<Runnable>());;
            System.out.println(pool.getPoolSize());//0
            for (int i = 0; i < 2; i++) {
                pool.submit(new Runnable() {
                    @Override
                    public void run() {
                        System.out.println("hehe");
                        try {
                            Thread.sleep(3000);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                });
            }
    
    
            System.out.println(pool.getPoolSize());//2
            Thread.sleep(4000);
            System.out.println(pool.getPoolSize());//2
    
        }