Java中怎么使用Executor接口

这篇文章将为大家详细讲解有关Java中怎么使用Executor接口，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。

一、Executor接口的理解

• Executor属于java.util.concurrent包下；

• Executor是任务执行机制的核心接口；

二、Executor接口的类图结构

由类图结构可知：

• ThreadPoolExecutor 继承了AbstractExecutorService接口；

• AbstractExecutorService接口实现了ExecutorService接口；

• ExecutorService继承了Executor接口；

• 因此以下部分主要讲解ThreadPoolExecutor类。

三、Executor接口中常用的方法

void execute(Runnable command) 在将来的某个时间执行给定的命令。 该命令可以在一个新线程，一个合并的线程中或在调用线程中执行，由Executor实现。

四、线程池的创建分为两种方式（主要介绍通过ThreadPoolExecutor方式）

注：通过Executors类的方式创建线程池，参考lz此博文链接https://www.yisu.com/article/215163.htm

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.*;


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构造函数。

关于Java中怎么使用Executor接口就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。