Java Executor接口 Java并发编程之Executor接口的使用
小志的博客 人气:0想了解Java并发编程之Executor接口的使用的相关内容吗，小志的博客在本文为您仔细讲解Java Executor接口的相关知识和一些Code实例，欢迎阅读和指正，我们先划重点：Java,Executor接口,Java接口，下面大家一起来学习吧。
一、Executor接口的理解
- Executor属于java.util.concurrent包下；
- Executor是任务执行机制的核心接口；
二、Executor接口的类图结构
由类图结构可知：
- ThreadPoolExecutor 继承了AbstractExecutorService接口；
- AbstractExecutorService接口实现了ExecutorService接口；
- ExecutorService继承了Executor接口；
- 因此以下部分主要讲解ThreadPoolExecutor类。
三、Executor接口中常用的方法
void execute(Runnable command) 在将来的某个时间执行给定的命令。 该命令可以在一个新线程，一个合并的线程中或在调用线程中执行，由Executor实现。
四、线程池的创建分为两种方式（主要介绍通过ThreadPoolExecutor方式）
注：通过Executors类的方式创建线程池，参考lz此博文链接https:
1.ThreadPoolExecutor类中的构造方法
public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue workQueue,defaultHandler)
2、 ThreadPoolExecutor类中构造函数的参数解析
- corePoolSize 核心线程最大数量，通俗点来讲就是，线程池中常驻线程的最大数量
- maximumPoolSize 线程池中运行最大线程数(包括核心线程和非核心线程)
- keepAliveTime线程池中空闲线程（仅适用于非核心线程）所能存活的最长时间
- unit 存活时间单位，与keepAliveTime搭配使用
- workQueue 存放任务的阻塞队列
- handler 线程池饱和策略
3、ThreadPoolExecutor类创建线程池示例
代码
package com.xz.thread.executor;
import java.util.concurrent.*;
/**
* @description:
* @author: xz
* @create: 2021-06-16 22:16
*/
public class Demo {
public static void main(String[] args) {
ThreadPoolExecutor pool = new ThreadPoolExecutor(3,3,
1L, TimeUnit.MINUTES,new LinkedBlockingDeque<>());
for(int i=1;i<=5;i++){
pool.execute(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getName());
try {
Thread.sleep(1000);
System.out.println("睡眠一秒钟");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
}
}
}
输出结果如下图
结论：无论是创建何种类型线程池(newFixedThreadPool、newSingleThreadExecutor、newCachedThreadPool等等)，均会调用ThreadPoolExecutor构造函数。
加载全部内容