Java的Executor线程池框架怎么使用

技术Java的Executor线程池框架怎么使用本篇内容介绍了“Java的Executor线程池框架怎么使用”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧

本文介绍了关于“如何使用Java的Executor线程池框架”的知识。很多人在实际案件操作中都会遇到这样的困难。接下来,让边肖带领大家学习如何应对这些情况!希望大家认真阅读,学点东西!

00-

一、Executor框架简介

1、基础简介

Executor系统设计用于分离线程任务提交和任务执行。Executor有各种强大的实现类,提供了提交任务和获取任务执行结果的便捷方式,封装了任务执行的过程,不再需要Thread()。start()方法显式创建线程并关联要执行的任务。

2、调度模型

线程一对一映射到服务所在的操作系统线程,启动时会创建一个操作系统线程;当线程终止时,操作系统线程也将被回收。

Java的Executor线程池框架怎么使用

3、核心API结构

Executor框架包含核心接口和主要实现类,如下图所示:

Java的Executor线程池框架怎么使用

线程池任务:核心接口:可运行、可调用接口和接口实现类;

任务的结果:接口未来和实现类未来任务;

任务的执行:核心接口执行器和执行器服务接口。执行器框架中有两个实现执行器服务接口的核心类,ThreadPoolExecutor和ScheduledThreadPoolExecutor。

二、用法案例

1、API基础

ThreadPoolExecutor基础构造

publichthreadpoolexecutor(intcorePoolSize,

intmaximumPoolSize,

longkeepAliveTime,

时间单位单位,

BlockingQueueRunnableworkQueue,

线程工厂线程工厂,

DesiredexecutionHandlerhandler参数名描述核心。

PoolSize线程池的核心大小,队列没满时,线程最大并发数maximumPoolSize最大线程池大小,队列满后线程能够容忍的最大并发数keepAliveTime空闲线程等待回收的时间限制unitkeepAliveTime时间单位workQueue阻塞的队列类型threadFactory创建线程的工厂,一般用默认即可handler超出工作队列和线程池时,任务会默认抛出异常

2、初始化方法

ExecutorService :Executors.newFixedThreadPool();ExecutorService :Executors.newSingleThreadExecutor();ExecutorService :Executors.newCachedThreadPool();ThreadPoolExecutor :new ThreadPoolExecutor() ;

通常情况下,线程池不允许使用Executors去创建,而是通过ThreadPoolExecutor的方式,这样的处理方式更加明确线程池的运行规则,规避资源耗尽的风险。

3、基础案例

package com.multy.thread.block08executor;
import java.util.concurrent.*;
public class Executor01 {
    // 定义线程池
    private static ThreadPoolExecutor poolExecutor = new ThreadPoolExecutor(
                    3,10,5000,TimeUnit.SECONDS,
                    new SynchronousQueue<>(),Executors.defaultThreadFactory(),new ExeHandler());
    public static void main(String[] args) {
        for (int i = 0 ; i < 100 ; i++){
            poolExecutor.execute(new PoolTask(i));
            //带返回值:poolExecutor.submit(new PoolTask(i));
        }
    }
}
// 定义线程池任务
class PoolTask implements Runnable {
    private int numParam;
    public PoolTask (int numParam) {
        this.numParam = numParam;
    }
    @Override
    public void run() {
        try {
            System.out.println("PoolTask "+ numParam+" begin...");
            Thread.sleep(5000);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    public int getNumParam() {
        return numParam;
    }
    public void setNumParam(int numParam) {
        this.numParam = numParam;
    }
}
// 定义异常处理
class ExeHandler implements RejectedExecutionHandler {
    @Override
    public void rejectedExecution(Runnable runnable, ThreadPoolExecutor executor) {
        System.out.println("ExeHandler "+executor.getCorePoolSize());
        executor.shutdown();
    }
}

流程分析

  • 线程池中线程数小于corePoolSize时,新任务将创建一个新线程执行任务,不论此时线程池中存在空闲线程;

  • 线程池中线程数达到corePoolSize时,新任务将被放入workQueue中,等待线程池中任务调度执行;

  • 当workQueue已满,且maximumPoolSize>corePoolSize时,新任务会创建新线程执行任务;

  • 当workQueue已满,且提交任务数超过maximumPoolSize,任务由RejectedExecutionHandler处理;

  • 当线程池中线程数超过corePoolSize,且超过这部分的空闲时间达到keepAliveTime时,回收该线程;

  • 如果设置allowCoreThreadTimeOut(true)时,线程池中corePoolSize范围内的线程空闲时间达到keepAliveTime也将回收;

三、线程池应用

应用场景:批量账户和密码的校验任务,在实际的业务中算比较常见的,通过初始化线程池,把任务提交执行,最后拿到处理结果,这就是线程池使用的核心思想:节省资源提升效率。

public class Executor02 {
    public static void main(String[] args) {
        // 初始化校验任务
        List<CheckTask> checkTaskList = new ArrayList<>() ;
        initList(checkTaskList);
        // 定义线程池
        ExecutorService executorService ;
        if (checkTaskList.size() < 10){
            executorService = Executors.newFixedThreadPool(checkTaskList.size());
        }else{
            executorService = Executors.newFixedThreadPool(10);
        }
        // 批量处理
        List<Future<Boolean>> results = new ArrayList<>() ;
        try {
            results = executorService.invokeAll(checkTaskList);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        // 查看结果
        for (Future<Boolean> result : results){
            try {
                System.out.println(result.get());
                // System.out.println(result.get(10000,TimeUnit.SECONDS));
            } catch (Exception e) {
                e.printStackTrace() ;
            }
        }
        // 关闭线程池
        executorService.shutdownNow();
    }
    private static void initList (List<CheckTask> checkTaskList){
        checkTaskList.add(new CheckTask("root","123")) ;
        checkTaskList.add(new CheckTask("root1","1234")) ;
        checkTaskList.add(new CheckTask("root2","1235")) ;
    }
}
// 校验任务
class CheckTask implements Callable<Boolean> {
    private String userName ;
    private String passWord ;
    public CheckTask(String userName, String passWord) {
        this.userName = userName;
        this.passWord = passWord;
    }
    @Override
    public Boolean call() throws Exception {
        // 校验账户+密码
        if (userName.equals("root") && passWord.equals("123")){
            return Boolean.TRUE ;
        }
        return Boolean.FALSE ;
    }
}

线程池主要用来解决线程生命周期开销问题和资源不足问题,通过线程池对多个任务线程重复使用,线程创建也被分摊到多个任务上,多数任务提交就有空闲的线程可以使用,所以消除线程频繁创建带来的开销。

“Java的Executor线程池框架怎么使用”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注网站,小编将为大家输出更多高质量的实用文章!

内容来源网络,如有侵权,联系删除,本文地址:https://www.230890.com/zhan/126958.html

(0)

相关推荐

  • Java反序列化回显与内存马注入

    技术Java反序列化回显与内存马注入 Java反序列化回显与内存马注入Java反序列化回显与内存马注入
    写在前面
    之前已经对于Tomcat回显链和简单的内存马注入进行了部分的学习,打算先对一个很常见的场

    礼包 2021年12月15日
  • 从数据库到可视化性能分析python

    技术从数据库到可视化性能分析python本篇内容主要讲解“从数据库到可视化性能分析python”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“从数据库到可视化性能分析pytho

    攻略 2021年11月26日
  • PostgreSQL中make_rel_from_joinlist函数分析

    技术PostgreSQL中make_rel_from_joinlist函数分析这篇文章主要介绍“PostgreSQL中make_rel_from_joinlist函数分析”,在日常操作中,相信很多人在PostgreSQL

    攻略 2021年11月10日
  • 和某人交谈用英语怎么说,与什么什么交流用英语怎么说

    技术和某人交谈用英语怎么说,与什么什么交流用英语怎么说communicate with sb.或者chat with sb.communicate的基本意思是“传达”“表达”,指把信息和某人交谈用英语怎么说、知识、性能等

    生活 2021年10月29日
  • React5种非常流行的状态管理库是什么

    技术React5种非常流行的状态管理库是什么本篇内容主要讲解“React 5种非常流行的状态管理库是什么”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“React 5种非常流行

    攻略 2021年10月26日
  • Act Framework多模块开发指南是什么

    技术Act Framework多模块开发指南是什么这篇文章给大家介绍Act Framework多模块开发指南是什么,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。ActFramework 是一个Jav

    攻略 2021年10月20日