我的编程空间,编程开发者的网络收藏夹
学习永远不晚

Java并发编程之Executors类详解

短信预约 -IT技能 免费直播动态提醒
省份

北京

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团
手机号立即预约

请填写图片验证码后获取短信验证码

看不清楚,换张图片

免费获取短信验证码

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;


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;


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;


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;


public class Demo {
    public static void main(String[] args) {
        //创建执行周期性任务的线程池
        ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);
        
        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类内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网!

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

Java并发编程之Executors类详解

下载Word文档到电脑,方便收藏和打印~

下载Word文档

猜你喜欢

详解Java并发编程之原子类

这篇文章主要为大家介绍了Java并发编程之原子类介绍,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
2023-05-18

java并发编程详解

一.synchronized的缺陷synchronized是java中的一个关键字,也就是说是Java语言内置的特性。那么为什么会出现Lock呢?如果一个代码块被synchronized修饰了,当一个线程获取了对应的锁,并执行该代码块时,其他线程便只能一直等待
java并发编程详解
2016-07-17

Java并发编程之显式锁机制详解

我们之前介绍过synchronized关键字实现程序的原子性操作,它的内部也是一种加锁和解锁机制,是一种声明式的编程方式,我们只需要对方法或者代码块进行声明,Java内部帮我们在调用方法之前和结束时加锁和解锁。而我们本篇将要
2023-05-30

Golang并发编程之Channel详解

传统的并发编程模型是基于线程和共享内存的同步访问控制的,共享数据受锁的保护,使用线程安全的数据结构会使得这更加容易。本文将详细介绍Golang并发编程中的Channel,,需要的朋友可以参考下
2023-05-19

编程热搜

  • Python 学习之路 - Python
    一、安装Python34Windows在Python官网(https://www.python.org/downloads/)下载安装包并安装。Python的默认安装路径是:C:\Python34配置环境变量:【右键计算机】--》【属性】-
    Python 学习之路 - Python
  • chatgpt的中文全称是什么
    chatgpt的中文全称是生成型预训练变换模型。ChatGPT是什么ChatGPT是美国人工智能研究实验室OpenAI开发的一种全新聊天机器人模型,它能够通过学习和理解人类的语言来进行对话,还能根据聊天的上下文进行互动,并协助人类完成一系列
    chatgpt的中文全称是什么
  • C/C++中extern函数使用详解
  • C/C++可变参数的使用
    可变参数的使用方法远远不止以下几种,不过在C,C++中使用可变参数时要小心,在使用printf()等函数时传入的参数个数一定不能比前面的格式化字符串中的’%’符号个数少,否则会产生访问越界,运气不好的话还会导致程序崩溃
    C/C++可变参数的使用
  • css样式文件该放在哪里
  • php中数组下标必须是连续的吗
  • Python 3 教程
    Python 3 教程 Python 的 3.0 版本,常被称为 Python 3000,或简称 Py3k。相对于 Python 的早期版本,这是一个较大的升级。为了不带入过多的累赘,Python 3.0 在设计的时候没有考虑向下兼容。 Python
    Python 3 教程
  • Python pip包管理
    一、前言    在Python中, 安装第三方模块是通过 setuptools 这个工具完成的。 Python有两个封装了 setuptools的包管理工具: easy_install  和  pip , 目前官方推荐使用 pip。    
    Python pip包管理
  • ubuntu如何重新编译内核
  • 改善Java代码之慎用java动态编译

目录