线程池的相关内容(常见的四种线程池类型,参数定义等)

it2023-09-22  78

一.什么是线程池 java.util.concurrent.Executor接口的实现用于创建线程池。 假设一个服务器完成一项任务所需的时间为: T1:创建线程时间 T2:业务逻辑执行时间 T3:线程销毁时间 若T1+T3>>T2,此时考虑使用线程池。线程池能节省服务器资源,更大限度的降低处理器闲置时间。提高处理效率。 作用: 1.提高效率 使用线程时,直接从线程池中获取,节省了创建时间和销毁时间。提高了项目执行效率 2.方便管理 线程池中固定的线程数,多余线程数的任务进入等待队列,等待队列满了之后,调用配置的拒绝策略。 二.四种常见的线程池 1、newSingleThreadExecutor 拥有单个线程的线程池,串行执行任务 2、newFixedThreadPool 固定数量的线程池,每提交一个事务,使用一个线程,当主要线程使用完了,往队列里放,队列里放完了,在创建线程,知道创建至最大线程数。 3、newCachedThreadPool 可缓存线程池,当线程池大小超过了处理任务所需的线程,那么就会回收部分空闲(一般是60秒无执行)的线程,当有任务来时,又智能的添加新线程来执行。 4、newScheduledThreadPool 创建一个定长的线程池,支持定时和周期性的执行任务。 三.为什么不建议使用Executors中的静态方法来创建线程池? 线程池不允许使用Executors去创建,需要通过ThreadPoolExecutor区创建线程池。这样更能明白线程池的运行原理,从而避免资源浪费和因为使用静态方法创建而产生OOM。 Executors返回的线程池对象的弊端如下: 1:FixedThreadPool 和 SingleThreadPool: 允许的请求队列(底层实现是LinkedBlockingQueue)长度为Integer.MAX_VALUE,可能会堆积大量的请求,从而导致OOM 2:CachedThreadPool 和 ScheduledThreadPool 允许的创建线程数量为Integer.MAX_VALUE,可能会创建大量的线程,从而导致OOM。 四.使用ThreadPoolExecutor创建线程池

import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ExecutorService; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class Test { private ExecutorService executor = new ThreadPoolExecutor(5, 10, 60, TimeUnit.SECONDS, new ArrayBlockingQueue(10)); }

常用参数: int corePoolSize,核心线程数量 int maximumPoolSize,最大线程数量 long keepAliveTime,超过核心线程数量的线程空闲的最大时间 TimeUnit unit,空闲时间单位 BlockingQueue workQueue 阻塞队列 threadFactory:创建线程的工厂类 handler:当线程已满,工作队列也满了的时候,调用拒绝策略

最新回复(0)