亲宝软件园·资讯

展开

Java Executors类 Java并发编程之Executors类详解

小志的博客 人气:0
想了解Java并发编程之Executors类详解的相关内容吗,小志的博客在本文为您仔细讲解Java Executors类的相关知识和一些Code实例,欢迎阅读和指正,我们先划重点:Java,Executors类,Java类,下面大家一起来学习吧。

一、Executors的理解

jdk1.8API中的解释如下:

在这里插入图片描述 

二、Executors类图结构

在这里插入图片描述

三、Executors常用的方法

在这里插入图片描述

四、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构造函数中的参数解析

加载全部内容

相关教程
猜你喜欢
用户评论