目录
- Executor
- ThreadPoolExecutor
- Executors
- execute vs submit
- 总结
1. Executor
Executor 是一个核心接口,真正线程池的实现是 ThreadPoolExecutor 类。注意 Executor(接口) -> ExecutorService(接口) -> AbstractExecutorService -> ThreadPoolExecutor 这条继承关系线
2. ThreadPoolExecutor
ThreadPoolExecutor 的构造方法包含如下参数:
- corePoolSize:线程池的核心线程数,默认核心线程会在线程池中一直存活
- maximumPoolSize:线程池所能容纳的最大线程数
- keepAliveTime:非核心线程的闲置时间,超过该时长非核心线程就会被回收。若设置 ThreadPoolExecutor 的 allowCoreThreadTimeOut 属性为 true,则 keepAliveTime 也会作用于核心线程
- unit:keepAliveTime 参数的时间单位,是一个名字为 TimeUnit 的枚举
- workQueue:线程池中的任务队列
- threadFactory:为线程池提供创建新线程的线程工厂类
ThreadPoolExecutor 执行任务的大致步骤:
- 若线程池中的线程数量未达到核心线程数,则直接启动一个核心线程来执行任务
- 若线程数量已经达到了核心线程的数量,则任务被插入任务队列中进行等待
- 若任务队列已满且线程数未达到规定的最大值,则启动一个非核心线程来执行任务
- 若启动的线程数也已经到达了最大值,则拒绝执行此任务,调用 RejectedExecutionHandler 的 rejectedExecution() 方法通知调用者
3. Executors
Executors 提供了一系列工厂方法用于创建线程池,返回的线程池都实现了 ExecutorService 接口(注意 ExecutorService 的具体实现者是 ThreadPoolExecutor 类)。线程池的分类如下:
- FixedThreadPool:线程池中只有核心线程并且这些线程没有超时限制,任务队列也没有大小限制
- CachedThreadPool:只有非核心线程,空闲线程的超时时长为 60 秒,它的任务队列是一个无法插入元素的特殊队列,也就意味着到来的任务会被立即执行
- ScheduledThreadPool:核心线程数量固定,非核心线程数量没有限制,非核心线程闲置时会被立即回收,主要用于执行定时任务和重复任务
- SingleThreadExecutor:只有一个核心线程,它确保每个任务都在同一个线程中执行,因而不需要处理线程间的同步问题
4. execute vs submit
- 线程池执行任务时,可以掉用 Executor 定义的 execute() 方法提交 Runnable 任务,也可以调用 ExecutorService 定义的 submit() 方法提交 Callable 任务
- 区别在于后者会返回一个 Future 对象,通过 Future 对象可以方便的取消任务的执行或者获取任务的当前状态等
5. 总结
- Executor 框架包括:Executor,ExecutorService,ThreadPoolExecutor,Executors
- Executor 是一个核心接口,定义了一个方法 execute(r)
- ExecutorService 接口继承自 Executor 接口,它有两个提交任务的方法 execute() 和 submit()
- Executors 提供了一系列工厂方法用于创建线程池,返回的线程池都实现了 ExecutorService 接口
- 可以用 Executor 定义的 execute() 方法提交 Runnable 任务,也可以用 ExecutorService 定义的 submit() 方法提交 Callable 任务,后者会返回一个 Future 对象,通过 它可以方便的取消任务的执行或获取任务的当前状态等
网友评论