Java并发编程之Executors类详解

2024-04-02 19:04:59 601人浏览八月长安

Python 官方文档：入门教程 => 点击学习

摘要

一、Executors的理解 Executors类属于java.util.concurrent包；线程池的创建分为两种方式：ThreadPoolExecutor

一、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());
    }
}

输出结果如下图

在这里插入图片描述