脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Java Executors类

Java并发编程之Executors类详解

 更新时间：2021年06月17日 15:55:57   作者：小志的博客  
今天给大家带来的是关于Java并发编程的相关知识,文章围绕着Java Executors类展开,文中有非常详细的介绍及代码示例,需要的朋友可以参考下

一、Executors的理解

  • Executors类属于java.util.concurrent包；
  • 线程池的创建分为两种方式：ThreadPoolExecutor 和 Executors；
  • Executors（静态Executor工厂）用于创建线程池；
  • 工厂和工具方法Executor ， ExecutorService ， ScheduledExecutorService ， ThreadFactory和Callable在此包中定义的类；

jdk1.8API中的解释如下:

在这里插入图片描述 

二、Executors类图结构

在这里插入图片描述

三、Executors常用的方法

在这里插入图片描述

  • 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版本新增的方法 )

四、Executors类中常用方法示例

1、newFixedThreadPool方法示例

代码

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<5;i++){
            fixedThreadPool.execute(new Runnable() {
                @Override
                public void run() {
                    System.out.println(Thread.currentThread().getName());
                    try {
                        Thread.sleep(500);
                        System.out.println("睡眠一秒");
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            });
        }

    }
}

输出结果如下图

在这里插入图片描述

结论：示例中创建了数量固定为3的线程，由输出结果截图可知，遍历次数为5次，当执行一轮（3次）后，停顿一秒钟，直到有线程空闲出来，才继续第4次执行。

2、newSingleThreadExecutor方法示例

代码

package com.xz.thread.executor;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * @description:
 * @author: xz
 * @create: 2021-06-15 22:33
 */
public class Demo {
    public static void main(String[] args) {
        //创建单个线程
        ExecutorService singleThreadPool = Executors.newSingleThreadExecutor();
        for(int i=0;i<5;i++){
            singleThreadPool.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();
                    }
                }
            });
        }

    }
}

输出结果如下图

在这里插入图片描述

结论：示例中创建了创建单个线程，每执行一次任务后，睡眠一秒，保证顺序地执行各个任务。

3、newCachedThreadPool方法 代码

package com.xz.thread.executor;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * @description:
 * @author: xz
 * @create: 2021-06-15 22:33
 */
public class Demo {
    public static void main(String[] args) {
        //创建带有缓存功能的线程池
        ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
        for(int i=0;i<5;i++){
            cachedThreadPool.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();
                    }
                }
            });
        }

    }
}

输出结果如下图

在这里插入图片描述

结论：示例中根据需要创建带有缓存线程的线程池，并在可用时将重新使用以前构造的线程。

4、newScheduledThreadPool方法示例

代码

package com.xz.thread.executor;

import java.time.LocalDateTime;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/**
 * @description:
 * @author: xz
 * @create: 2021-06-15 22:33
 */
public class Demo {
    public static void main(String[] args) {
        //创建执行周期性任务的线程池
        ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);
        /**
         * schedule(Runnable command,long delay, TimeUnit unit)方法参数解析
         * command 表示执行任务命令
         * delay 表示从现在开始延迟执行的时间
         * unit  延时参数的时间单位
         */
        scheduledThreadPool.schedule(new Runnable() {
            @Override
            public void run() {
                System.out.println("scheduledThreadPool:"+LocalDateTime.now());
            }
        },1L, TimeUnit.MINUTES);
        System.out.println("当前时间："+LocalDateTime.now());
    }
}

输出结果如下图

在这里插入图片描述

结论：示例中创建执行周期性或定时性任务的线程池，由输出结果可知，设置的1分钟后执行任务已经生效。

五、Executors创建线程池原理

1、无论是创建何种类型线程池(newFixedThreadPool、newSingleThreadExecutor、newCachedThreadPool等等)，均会调用ThreadPoolExecutor构造函数。

在这里插入图片描述

在这里插入图片描述
在这里插入图片描述

2、 ThreadPoolExecutor构造函数中的参数解析

  • corePoolSize 核心线程最大数量，通俗点来讲就是，线程池中常驻线程的最大数量
  • maximumPoolSize 线程池中运行最大线程数(包括核心线程和非核心线程)
  • keepAliveTime 线程池中空闲线程（仅适用于非核心线程）所能存活的最长时间
  • unit 存活时间单位，与keepAliveTime搭配使用
  • workQueue 存放任务的阻塞队列
  • handler 线程池饱和策略

到此这篇关于Java并发编程之Executors类详解的文章就介绍到这了,更多相关Java Executors类内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • 解决SpringBoot application.yaml文件配置schema 无法执行sql问题

    解决SpringBoot application.yaml文件配置schema 无法执行sql问题

    这篇文章主要介绍了解决SpringBoot application.yaml文件配置schema 无法执行sql问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-08-08
  • Java利用cors实现跨域请求实例

    Java利用cors实现跨域请求实例

    本篇文章主要介绍了Java利用cors实现跨域请求实例，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-05-05
  • Spring Boot实现JWT token自动续期的实现

    Spring Boot实现JWT token自动续期的实现

    本文主要介绍了Spring Boot实现JWT token自动续期，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2021-12-12
  • Java Speech API实现语音识别

    Java Speech API实现语音识别

    Java语音识别是一项非常有用的功能,它可以将语音转换为文本,从而实现语音输入和语音控制功能,在当今数字化时代,语音识别技术逐渐成为人机交互的重要方式之一,语音识别技术可以帮助我们将语音数据转化为文字,进而进行后续的处理和分析
    2023-10-10
  • SpringBoot内部外部配置文件加载顺序解析

    SpringBoot内部外部配置文件加载顺序解析

    这篇文章主要介绍了SpringBoot内部外部配置文件加载顺序解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-07-07
  • Hibernate三种状态和Session常用的方法

    Hibernate三种状态和Session常用的方法

    本文主要介绍了Hibernate三种状态和Session常用的方法，具有很好的参考价值，下面跟着小编一起来看下吧
    2017-03-03
  • 教你利用springboot集成swagger并生成接口文档

    教你利用springboot集成swagger并生成接口文档

    有很多小伙伴不会利用springboot集成swagger并生成接口文档,今天特地整理了这篇文章,文中有非常详细的代码图文介绍及代码示例,对不会这个方法的小伙伴们很有帮助,需要的朋友可以参考下
    2021-05-05
  • Java实战之电影在线观看系统的实现

    Java实战之电影在线观看系统的实现

    这篇文章主要介绍了如何利用Java实现电影在线观看系统，文中用到的技术有：JSP、Spring、SpringMVC、MyBatis等，感兴趣的可以了解一下
    2022-04-04
  • SpringBoot+SpringCloud用户信息微服务传递实现解析

    SpringBoot+SpringCloud用户信息微服务传递实现解析

    这篇文章主要介绍了SpringBoot+SpringCloud实现登录用户信息在微服务之间的传递,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-11-11
  • 你知道怎么用Spring的三级缓存解决循环依赖吗

    你知道怎么用Spring的三级缓存解决循环依赖吗

    这篇文章主要为大家详细介绍了Spring的三级缓存解决循环依赖，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助
    2022-02-02

最新评论