目录
一、Executors的理解
- 一、Executors的理解
- 二、Executors类图结构
- 二、Executors常用的方法
- 三、线程池的创建分为两种方式(主要介绍通过Executors类创建的方式)
- 1、newFixedThreadPool方法示例
- 2、newSingleThreadExecutor方法示例
- 3、newCachedThreadPool方法
- 4、newScheduledThreadPool方法示例
- 四、Executors创建线程池原理
- Executors类属于java.util.concurrent包;
- 线程池的创建分为两种方式:ThreadPoolExecutor 和 Executors;
- Executors(静态Executor工厂)用于创建线程池;
- 工厂和工具方法Executor , ExecutorService , ScheduledExecutorService , ThreadFactory和Callable在此包中定义的类;
- jdk1.8API中的解释如下:
- public static ExecutorService newFixedThreadPool(int nThreads) 一种线程数量固定的线程池,当线程处于空闲状态时,他们并不会被回收,除非线程池被关闭。当所有的线程都处于活动状态时,新的任务都会处于等待状态,直到有线程空闲出来。
- public static ExecutorService newSingleThreadExecutor() 创建单个线程。它适用于需要保证顺序地执行各个任务;并且在任意时间点,不会有多个线程是活动的应用场景;如果单个线程挂掉后,会重启一个线程继续执行任务。
- public static ExecutorService newCachedThreadPool() 创建一个根据需要创建新线程的线程池,但在可用时将重新使用以前构造的线程, 如果没有可用的线程,将创建一个新的线程并将其添加到该池中。 未使用六十秒的线程将被终止并从缓存中删除;即用的时候创建线程,不用的时候销毁线程。 - public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) 创建一个线程池,可以调度命令在给定的延迟之后运行,或定期执行;支持执行定时性或周期性任务。
- public static ExecutorService newWorkStealingPool(int parallelism) jdk1.8才出现的,创建一个维护足够的线程以支持给定的并行级别的线程池,并且可以使用多个队列来减少争用。 ( jdk1.8版本新增的方法 )
-
代码
package com.xz.thread.executors; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; /** * @description: * @author: xz * @create: 2021-06-16 21:33 */ public class Demo { public static void main(String[] args) { //创建数量固定的线程池,线程池数量为3 ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3); for(int i=0;i
关注打赏
热门博文
- Netty—— 概念剖析(NIO vs BIO)
- Netty——网络编程 NIO(Selector处理accept事件)代码示例
- CompletableFuture异步编排(多任务组合)
- CompletableFuture异步编排(两任务组合——两个任务必须都完成才触发另一个任务 )
- CompletableFuture异步编排(线程串行化代码示例)
- CompletableFuture异步编排(handle最终处理)
- CompletableFuture异步编排(计算完成回调代码示例)
- hutool工具导出excel代码示例
- CompletableFuture异步编排(开启异步编程代码示例)
- java 获取音频、视频文件时长代码示例