线程池的处理流程
文章图片
创建线程池的方法
创建线程池的方法如下:
public ThreadPoolExecutor(
int corePoolSize,//核心线程数量
int maximumPoolSize,//线程池最大数量
long keepAliveTime,//线程存活时间
TimeUnit unit,//时间单位
BlockingQueue runnableTaskQueue,//任务队列
ThreadFactory threadFactory,//线程工厂
RejectedExecutionHandler handler//拒绝策略
);
参数详解
- corePoolSize:可同时运行的最小线程数量。
- maximumPoolSize:线程池允许创建的最大线程数量。
- keepAliveTime:核心线程外的其他线程空闲的最大时间,超过就销毁。
- unit:时间单位。
- runnableTaskQueue:用于保存等待执行的任务的阻塞队列。
- ArrayBlockingQueue: 基于数组结构的有界阻塞队列,按先进先出原则对元素进行排序。
- LinkedBlockingQueue:基于链表结构的阻塞队列,此队列按先进先出原则排序元素,吞吐量通常要高于ArrayBlockingQueue。
- SynchronousQueue:不存储元素的阻塞队列。每个插入操作必须等到另一个线程调用移除操作,否则插入操作一直处于阻塞状态,吞吐量通常要高于Linked-BlockingQueue。
- PriorityBlockingQueue:具有优先级的无限阻塞队列。
- threadFactory:线程工厂,用于创建新线程。
- handler:当线程池处于饱和状态,处理新任务的策略。
- AbortPolicy:直接抛出异常。
- CallerRunsPolicy:只用调用者所在线程来运行任务。
- DiscardOldestPolicy:丢弃队列里最近的一个任务,并执行当前任务。
- DiscardPolicy:不处理,丢弃掉。
合理的配置线程池需要从任务的角度来分析:
- 任务的性质:CPU 密集型的任务应设置核心线程数为 Ncpu+1。IO密集型任务应设置核心线程数为 2Ncpu 。
- 任务的优先级:考虑使用优先级队列PriorityBlockingQueue来处理。
- 任务的执行时间:可以使用不同规模的线程池或者使用优先级队列,优先执行时间短任务。
- 任务的依赖性:如果依赖数据库连接,由于线程提交 SQL 需要等待数据库返回结果,所以线程数应该设置得大,才能更好的减少 CPU 的等待时间,从而更好的利用 CPU。
- 提交不需要返回值的任务:execute()方法用于提交不需要返回值的任务,所以无法判断任务是否被线程池执行成功。
- 提交需要返回值的任务:submit() 方法用于提交需要返回值的任务。线程池会返回一个 future 类型的对象,可以通过 future 的 get() 方法来获取返回值,get() 方法会阻塞当前线程直到任务完成。