1. Python技术站首页
  2. 其他
  3. Java

10分钟带你徒手做个Java线程池

• Java

摘要：花10分钟开发一个极简版的Java线程池，让小伙伴们更好的理解线程池的核心原理。

本文分享自华为云社区《放大招了，冰河带你10分钟手撸Java线程池，yyds，赶快收藏吧》，作者：冰 河。

Java线程池核心原理

看过Java线程池源码的小伙伴都知道，在Java线程池中最核心的类就是ThreadPoolExecutor，而在ThreadPoolExecutor类中最核心的构造方法就是带有7个参数的构造方法，如下所示。

 public ThreadPoolExecutor(int corePoolSize,
 int maximumPoolSize,
 long keepAliveTime,
 TimeUnit unit,
 BlockingQueue<Runnable> workQueue,
 ThreadFactory threadFactory,
 RejectedExecutionHandler handler)

各参数的含义如下所示。

  • corePoolSize：线程池中的常驻核心线程数。
  • maximumPoolSize：线程池能够容纳同时执行的最大线程数，此值大于等于1。
  • keepAliveTime：多余的空闲线程存活时间，当空间时间达到keepAliveTime值时，多余的线程会被销毁直到只剩下corePoolSize个线程为止。
  • unit：keepAliveTime的单位。
  • workQueue：任务队列，被提交但尚未被执行的任务。
  • threadFactory：表示生成线程池中工作线程的线程工厂，用户创建新线程，一般用默认即可。
  • handler：拒绝策略，表示当线程队列满了并且工作线程大于等于线程池的最大显示数(maxnumPoolSize)时，如何来拒绝请求执行的runnable的策略。

并且Java的线程池是通过 生产者-消费者模式 实现的，线程池的使用方是生产者，而线程池本身就是消费者。

Java线程池的核心工作流程如下图所示。

10分钟带你徒手做个Java线程池

手撸Java线程池

我们自己手动实现的线程池要比Java自身的线程池简单的多，我们去掉了各种复杂的处理方式，只保留了最核心的原理：线程池的使用者向任务队列中添加任务，而线程池本身从任务队列中消费任务并执行任务。

10分钟带你徒手做个Java线程池

只要理解了这个核心原理，接下来的代码就简单多了。在实现这个简单的线程池时，我们可以将整个实现过程进行拆解。拆解后的实现流程为：定义核心字段、创建内部类WorkThread、创建ThreadPool类的构造方法和创建执行任务的方法。

10分钟带你徒手做个Java线程池

定义核心字段

首先，我们创建一个名称为ThreadPool的Java类，并在这个类中定义如下核心字段。

  • DEFAULT_WORKQUEUE_SIZE：静态常量，表示默认的阻塞队列大小。
  • workQueue：模拟实际的线程池使用阻塞队列来实现生产者-消费者模式。
  • workThreads：模拟实际的线程池使用List集合保存线程池内部的工作线程。

核心代码如下所示。

//默认阻塞队列大小
private static final int DEFAULT_WORKQUEUE_SIZE = 5;
//模拟实际的线程池使用阻塞队列来实现生产者-消费者模式
private BlockingQueue<Runnable> workQueue;
//模拟实际的线程池使用List集合保存线程池内部的工作线程
private List<WorkThread> workThreads = new ArrayList<WorkThread>();

创建内部类WordThread

在ThreadPool类中创建一个内部类WorkThread，模拟线程池中的工作线程。主要的作用就是消费workQueue中的任务，并执行任务。由于工作线程需要不断从workQueue中获取任务，所以，这里使用了while(true)循环不断尝试消费队列中的任务。

核心代码如下所示。

//内部类WorkThread，模拟线程池中的工作线程
//主要的作用就是消费workQueue中的任务，并执行
//由于工作线程需要不断从workQueue中获取任务，使用了while(true)循环不断尝试消费队列中的任务
class WorkThread extends Thread{
 @Override
 public void run() {
 //不断循环获取队列中的任务
 while (true){
 //当没有任务时，会阻塞
 try {
 Runnable workTask = workQueue.take();
 workTask.run();
 } catch (InterruptedException e) {
 e.printStackTrace();
 }
 }
 }
}

创建ThreadPool类的构造方法

这里，我们为ThreadPool类创建两个构造方法，一个构造方法中传入线程池的容量大小和阻塞队列，另一个构造方法中只传入线程池的容量大小。

核心代码如下所示。

//在ThreadPool的构造方法中传入线程池的大小和阻塞队列
public ThreadPool(int poolSize, BlockingQueue<Runnable> workQueue){
 this.workQueue = workQueue;
 //创建poolSize个工作线程并将其加入到workThreads集合中
 IntStream.range(0, poolSize).forEach((i) -> {
 WorkThread workThread = new WorkThread();
 workThread.start();
 workThreads.add(workThread);
 });
}
//在ThreadPool的构造方法中传入线程池的大小
public ThreadPool(int poolSize){
 this(poolSize, new LinkedBlockingQueue<>(DEFAULT_WORKQUEUE_SIZE));
}

创建执行任务的方法

在ThreadPool类中创建执行任务的方法execute()，execute()方法的实现比较简单，就是将方法接收到的Runnable任务加入到workQueue队列中。

核心代码如下所示。

//通过线程池执行任务
public void execute(Runnable task){
 try {
 workQueue.put(task);
 } catch (InterruptedException e) {
 e.printStackTrace();
 }
}

完整源码

这里，我们给出手动实现的ThreadPool线程池的完整源代码，如下所示。

package io.binghe.thread.pool;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.stream.IntStream;
/**
 * @author binghe
 * @version 1.0.0
 * @description 自定义线程池
 */
public class ThreadPool {
 //默认阻塞队列大小
 private static final int DEFAULT_WORKQUEUE_SIZE = 5;
 //模拟实际的线程池使用阻塞队列来实现生产者-消费者模式
 private BlockingQueue<Runnable> workQueue;
 //模拟实际的线程池使用List集合保存线程池内部的工作线程
 private List<WorkThread> workThreads = new ArrayList<WorkThread>();
 //在ThreadPool的构造方法中传入线程池的大小和阻塞队列
 public ThreadPool(int poolSize, BlockingQueue<Runnable> workQueue){
 this.workQueue = workQueue;
 //创建poolSize个工作线程并将其加入到workThreads集合中
 IntStream.range(0, poolSize).forEach((i) -> {
 WorkThread workThread = new WorkThread();
 workThread.start();
 workThreads.add(workThread);
 });
 }
 //在ThreadPool的构造方法中传入线程池的大小
 public ThreadPool(int poolSize){
 this(poolSize, new LinkedBlockingQueue<>(DEFAULT_WORKQUEUE_SIZE));
 }
 //通过线程池执行任务
 public void execute(Runnable task){
 try {
 workQueue.put(task);
 } catch (InterruptedException e) {
 e.printStackTrace();
 }
 }
 //内部类WorkThread，模拟线程池中的工作线程
 //主要的作用就是消费workQueue中的任务，并执行
 //由于工作线程需要不断从workQueue中获取任务，使用了while(true)循环不断尝试消费队列中的任务
 class WorkThread extends Thread{
 @Override
 public void run() {
 //不断循环获取队列中的任务
 while (true){
 //当没有任务时，会阻塞
 try {
 Runnable workTask = workQueue.take();
 workTask.run();
 } catch (InterruptedException e) {
 e.printStackTrace();
 }
 }
 }
 }
}

没错，我们仅仅用了几十行Java代码就实现了一个极简版的Java线程池，没错，这个极简版的Java线程池的代码却体现了Java线程池的核心原理。

接下来，我们测试下这个极简版的Java线程池。

编写测试程序

测试程序也比较简单，就是通过在main()方法中调用ThreadPool类的构造方法，传入线程池的大小，创建一个ThreadPool类的实例，然后循环10次调用ThreadPool类的execute()方法，向线程池中提交的任务为：打印当前线程的名称--->> Hello ThreadPool。

整体测试代码如下所示。

package io.binghe.thread.pool.test;
import io.binghe.thread.pool.ThreadPool;
import java.util.stream.IntStream;
/**
 * @author binghe
 * @version 1.0.0
 * @description 测试自定义线程池
 */
public class ThreadPoolTest {
 public static void main(String[] args){
 ThreadPool threadPool = new ThreadPool(10);
 IntStream.range(0, 10).forEach((i) -> {
 threadPool.execute(() -> {
 System.out.println(Thread.currentThread().getName() + "--->> Hello ThreadPool");
 });
 });
 }
}

接下来，运行ThreadPoolTest类的main()方法，会输出如下信息。

Thread-0--->> Hello ThreadPool
Thread-9--->> Hello ThreadPool
Thread-5--->> Hello ThreadPool
Thread-8--->> Hello ThreadPool
Thread-4--->> Hello ThreadPool
Thread-1--->> Hello ThreadPool
Thread-2--->> Hello ThreadPool
Thread-5--->> Hello ThreadPool
Thread-9--->> Hello ThreadPool
Thread-0--->> Hello ThreadPool

至此，我们自定义的Java线程池就开发完成了。

总结

线程池的核心原理其实并不复杂，只要我们耐心的分析，深入其源码理解线程池的核心本质，你就会发现线程池的设计原来是如此的优雅。希望通过这个手写线程池的小例子，能够让你更好的理解线程池的核心原理。

 

点击关注，第一时间了解华为云新鲜技术~

原文链接：https://www.cnblogs.com/huaweiyun/p/17333748.html

本站文章如无特殊说明，均为本站原创，如若转载，请注明出处：10分钟带你徒手做个Java线程池 - Python技术站

赞 (0)
0 0 打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023年4月19日
下一篇 2023年4月20日

相关文章

  • Java实现选择排序

    下面我会详细讲解Java实现选择排序的完整攻略，过程中包含以下几点内容： 选择排序算法的基本介绍 选择排序算法的实现过程 选择排序算法的时间复杂度分析 两个Java示例说明选择排序的实现过程 1. 选择排序算法的基本介绍 选择排序算法（Selection Sort）是一种简单的排序算法，基本思路是从未排序序列中选出最小（或最大）的元素，将其放置到已排序序列的…

    Java 2023年5月19日
    00

  • 使用springboot开发的第一个web入门程序的实现

    使用Spring Boot开发的第一个Web入门程序的实现 Spring Boot是一个流行的Java框架，可以帮助开发人员快速构建和部署应用程序。本文将详细讲解如何使用Spring Boot开发第一个Web入门程序，包括创建Spring Boot项目、编写控制器和视图、运行应用程序等。 1. 创建Spring Boot项目 首先，我们需要创建一个Sprin…

    Java 2023年5月14日
    00

  • java中servlet实现登录验证的方法

    针对“java中servlet实现登录验证的方法”的完整攻略，我来进行详细讲解。 1. 基础登录验证实现方法 首先，我们要明确应用场景。一般来说，在Web应用程序中，登录验证是必不可少的部分。开发人员往往需要采用一定的技术手段，在用户输入用户名和密码的同时，实现对其身份的验证。 在Java Servlet中，我们可以通过以下步骤实现基础的登录验证： 接收用户…

    Java 2023年6月15日
    00

  • 阿里四面之Spring Exception的原理解析

    阿里四面之Spring Exception的原理解析 前言 在使用 Spring Framework 进行开发时，异常处理是必不可少的环节。Spring Exception（Spring 异常处理）是 Spring Framework 提供的异常处理机制。本文将详细探究 Spring Exception 的原理。 什么是 Spring Exception S…

    Java 2023年5月27日
    00

  • uni-app 微信小程序授权登录的实现步骤

    下面是详细讲解“uni-app 微信小程序授权登录的实现步骤”的完整攻略： 一、前置条件 在进行微信小程序授权登录之前，要确保以下几个前置条件已经满足： 已经注册微信小程序开发者账号，并创建了一个小程序。 在小程序后台设置了合法的“授权域名”。 在小程序后台开启了“用户信息”，并获取了对应的“AppID”和“AppSecret”。 二、授权登录实现步骤 接下…

    Java 2023年5月23日
    00

  • SpringMVC使用注解配置方式

    以下是关于“SpringMVC使用注解配置方式”的完整攻略，其中包含两个示例。 SpringMVC使用注解配置方式 SpringMVC是一个基于MVC模式的Web框架，它可以帮助我们快速开发Web应用程序。本文将介绍SpringMVC使用注解配置方式，并提供两个示例。 配置DispatcherServlet DispatcherServlet是SpringM…

    Java 2023年5月16日
    00

  • Java复制(拷贝)数组的4种方法：arraycopy()方法、clone() 方法、copyOf()和copyOfRan

    当我们需要在Java中复制(拷贝)数组时，有四种主要的方法可供选择: 使用arraycopy()方法 使用clone()方法 使用copyOf()方法 使用copyOfRange()方法 下面，我们将详细讲解这四种方法。 1. 使用arraycopy()方法 public static void arraycopy(Object src, int srcPo…

    Java 2023年5月26日
    00

  • 在JSP中使用formatNumber控制要显示的小数位数方法

    在JSP中，可以使用<fmt:formatNumber>标签来控制数字的显示格式，包括小数位数。 步骤如下： 在JSP页面中引入JSTL标签库： <%@taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c" %> <%@tagli…

    Java 2023年6月15日
    00
合作推广
合作推广
分享本页
返回顶部