线程池参数解析以及提交任务的流程

╰+攻爆jí腚メ 2022-10-15 13:50 96阅读 0赞

### 线程池参数解析以及提交任务的流程 ###

*  线程池的 6 个参数
 *  线程池处理新提交的任务

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDU5MzgzMA_size_16_color_FFFFFF_t_70][]

# 线程池的好处 #

*  降低资源消耗：通过重复利用已创建的线程降低线程创建和销毁造成的消耗。
 *  提高响应速度：当任务到达时，任务可以不需要等到线程创建就能立即执行。
 *  提高线程的可管理性：线程是稀缺资源，如果无限制地创建，不仅会消耗系统资源，还会降低系统的稳定性，使用线程池可以进行统一分配、调优和监控。

# 线程池的 6 个参数 #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDU5MzgzMA_size_16_color_FFFFFF_t_70 1][]  
ThreadPoolExecutor（Executor 接口的实现类）提供的构造方法：

## ThreadPoolExecutor有以下四个构造方法 ##

*  `ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)`
 *  `ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, -BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler)`
 *  `ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory)`
 *  `ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)`

1 `corePoolSize`（线程池的基本大小）:当提交一个任务到线程池时，线程池会创建一个线程来执行任务，即使其他空闲的基本线程能够执行新任务也会创建线程，等到需要执行的任务数大于线程池基本大小时就不再创建。如果调用了prestartAllCoreThreads()方法，线程池会提前创建并启动所有基本线程。

2 `workQueue(任务队列)` : 用于保存等待执行的任务的阻塞队列。可以选择以下几个阻塞队列：

*  ArrayBlockingQueue:是一个基于数组结构的有界阻塞队列，按FIFO原则进行排序
 *  LinkedBlockingQueue:一个基于链表结构的阻塞队列，吞吐量高于ArrayBlockingQueue。静态工厂方法Excutors.newFixedThreadPool()使用了这个队列
 *  SynchronousQueue: 一个不存储元素的阻塞队列。每个插入操作必须等到另一个线程调用移除操作，否则插入操作一直处于阻塞状态，吞吐量高于LinkedBlockingQueue，静态工厂方法Excutors.newCachedThreadPool()使用了这个队列
 *  PriorityBlockingQueue:一个具有优先级的无限阻塞队列。  
    3 `maximumPoolSize（线程池最大数量）`：线程池允许创建的最大线程数。如果队列满了，并且已创建的线程数小于最大线程数，则线程池会再创建新的线程执行任务。值得注意的是，如果使用了无界的任务队列这个参数就没用了。  
    4 `threadFactory（线程工厂）`：可以通过线程工厂为每个创建出来的线程设置更有意义的名字，如开源框架guava  
    5 `RejectedExecutionHandler （饱和策略）`：当队列和线程池都满了，说明线程池处于饱和状态，那么必须采取一种策略还处理新提交的任务。它可以有如下四个选项：
 *  AbortPolicy:直接抛出异常，默认情况下采用这种策略
 *  CallerRunsPolicy:只用调用者所在线程来运行任务
 *  DiscardOldestPolicy:丢弃队列里最近的一个任务，并执行当前任务
 *  DiscardPolicy:不处理，丢弃掉  
    更多的时候，我们应该通过实现RejectedExecutionHandler 接口来自定义策略，比如记录日志或持久化存储等。  
    6`keepAliveTime(线程活动时间)`:线程池的工作线程空闲后，保持存活的时间。所以如果任务很多，并且每个任务执行的时间比较短，可以调大时间，提高线程利用率。

7 `TimeUnit(线程活动时间的单位)`：可选的单位有天（Days）、小时（HOURS）、分钟（MINUTES）、毫秒（MILLISECONDS）、微秒（MICROSECONDS，千分之一毫秒）和纳秒（NANOSECONDS，千分之一微秒）。

# 线程池处理新提交的任务 #

当一个任务提交到线程池，线程池的处理流程：  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDU5MzgzMA_size_16_color_FFFFFF_t_70 2][]  
总结：任务进来之后，线程池会逐一判断 corePoolSize 、workQueue 、maxPoolSize ，如果依然不能满足需求，则会拒绝任务。

# 有两种方法向线程池提交任务： #

可以使用execute和submit两个方法向线程池提交任务

1.  `execute方法用于提交不需要返回值的任务，利用这种方式提交的任务无法得知是否正常执行`

threadPoolExecutor.execute(new Runnable() { 
    			
    			@Override
    			public void run() { 
    				try { 
    					Thread.sleep(5000);
    				} catch (InterruptedException e) { 
    					e.printStackTrace();
    				}
    			}
    		});

2.`submit方法用于提交一个任务并带有返回值，这个方法将返回一个Future类型对象。可以通过 这个返回对象判断任务是否执行成功，并且可以通过future.get()方法来获取返回值，get()方法会阻塞当前线程直到任务完成。`

Future<?> future=threadPoolExecutor.submit(futureTask);
    		
    		Object value=future.get();

# 关闭线程池的方法： #

1.shutdown()：一般都用这个  
2.shutdownNow()：任务不一定要执行完

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDU5MzgzMA_size_16_color_FFFFFF_t_70]: /images/20221014/dd1614012a614072b150a48c2cc8dee8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDU5MzgzMA_size_16_color_FFFFFF_t_70 1]: /images/20221014/c6c8f67f91de40b9824f0ba1b14d970e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDU5MzgzMA_size_16_color_FFFFFF_t_70 2]: /images/20221014/500e7e940ba040339136a42883cd317a.png