Java实现手写线程池实例并测试详解
作者:小威要向诸佬学习呀 时间:2022-03-04 11:23:27
前言
在之前的文章中介绍过线程池的核心原理,在一次面试中面试官让手写线程池,这块知识忘记的差不多了,因此本篇文章做一个回顾。
希望能够加深自己的印象以及帮助到其他的小伙伴儿们
在线程池核心原理篇介绍过线程池的核心原理,今天来模拟线程池和工作队列的流程,以及编写代码和测试类进行测试。下面附下之前线程池的核心流程:
在线程池核心原理的源码中,涉及到了一系列的流程,包括线程池队列数量是否已满,运用什么样的拒绝策略等。在我们手写线程池的代码中,不需要考虑那么多因素,只需要模拟简单的情景和过程,因此整体来讲还是比较简单的。
手写线程池,必不可少的组件有任务队列,任务的消费者线程池,线程池创建等。我们也可定义构造方法,创建指定大小的线程池线程个数。当然在使用完线程池中的线程后,我们需要考虑将其销毁或关闭。
相关代码和解释如下:
package XIAOWEI;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.stream.IntStream;
public class ThreadPool {
private static final int WorkQueueSIZE = 5;
private BlockingQueue<Runnable> workQueue;
private List<WorkThread> workThreads=new ArrayList<WorkThread>();
/**
* @author xiaowei
* @param poolSize
* @param workQueue
* 构造方法,传线程池的大小和阻塞队列
*/
public ThreadPool(int poolSize,BlockingQueue<Runnable> workQueue) {
this.workQueue = workQueue;
IntStream.range(0,poolSize).forEach((i)->{
WorkThread workThread=new WorkThread();
workThread.start();
workThreads.add(workThread);
});
}
/**
* @param poolSize
* 在ThreadPool的构造方法中传入线程池的大小
*/
public ThreadPool(int poolSize){
this(poolSize,new LinkedBlockingQueue<>(WorkQueueSIZE));
}
/**
* @param task
* 通过线程池执行任务
*/
public void extcute(Runnable task){
try {
workQueue.put(task);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public void shutdown(){
if(workThreads!=null && workThreads.size()>0){
workThreads.stream().forEach((workThread) -> {
workThread.interrupt();
});
}
}
/**
* 内部类 源源不断的消耗workQueue中的任务
*/
class WorkThread extends Thread {
@Override
public void run() {
Thread currentThread = Thread.currentThread();
// 死循环 不断一直消费队列中的任务 直到任务被消费完全
while (true) {
try {
if (currentThread.isInterrupted()) {
break;
}
Runnable workTasK = workQueue.take();
workTasK.run();
} catch (InterruptedException e) {
currentThread.interrupt();
}
}
}
}
}
相关测试代码如下:
package XIAOWEI;
import java.util.stream.IntStream;
public class ThreadPoolTest {
public static void main(String[] args) {
ThreadPool threadPool = new ThreadPool(5);
IntStream.range(0,10).forEach((i)->{
threadPool.extcute(()->{
System.out.println(Thread.currentThread().getName()+"2023一起加油");
});
});
threadPool.shutdown();
}
}
一共在线程池中加入了五个线程和十个任务,因此每个线程会执行两个任务。
测试结果如下图所示:
来源:https://blog.csdn.net/qq_53847859/article/details/129113884
标签:Java,线程池
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
Java线程池的优点及池化技术的应用
2022-07-01 08:12:23
![](https://img.aspxhome.com/file/2023/0/72290_0s.webp)
Java内存缓存工具Guava LoadingCache使用解析
2023-05-25 08:36:36
C#有效防止同一账号多次登录(附三种方法)
2023-05-23 10:32:45
java编写简单的ATM存取系统
2023-06-28 07:50:33
![](https://img.aspxhome.com/file/2023/4/89574_0s.png)
spring整合redis缓存并以注解(@Cacheable、@CachePut、@CacheEvict)形式使用
2022-04-25 01:46:14
Java 确保某个Bean类被最后执行的几种实现方式
2021-09-28 09:53:49
![](https://img.aspxhome.com/file/2023/8/99758_0s.png)
Android之网络通信案例分析
2023-10-21 02:13:20
![](https://img.aspxhome.com/file/2023/2/108232_0s.jpg)
并行Stream与Spring事务相遇会发生什么?
2022-08-28 15:40:12
![](https://img.aspxhome.com/file/2023/4/85944_0s.webp)
Android Studio 3.0 原生支持kotlin 例子详解
2023-10-30 04:28:14
![](https://img.aspxhome.com/file/2023/4/93334_0s.png)
解决@Api注解不展示controller内容的问题
2022-08-29 21:16:38
![](https://img.aspxhome.com/file/2023/5/87345_0s.png)
java之CSV大批量数据入库的实现
2021-06-30 15:53:49
![](https://img.aspxhome.com/file/2023/0/66170_0s.png)
解析C#多线程编程中异步多线程的实现及线程池的使用
2021-10-23 02:36:23
![](https://img.aspxhome.com/file/2023/7/75627_0s.png)
新手学习Java对Redis简单操作
2023-09-10 05:05:41
WPF实现动画效果(六)之路径动画
2022-02-05 01:42:15
在Unity中使用全局变量的操作
2022-12-30 13:18:47
![](https://img.aspxhome.com/file/2023/0/119550_0s.jpg)
Spring Bean 依赖注入常见错误问题
2022-10-02 20:46:51
![](https://img.aspxhome.com/file/2023/5/65755_0s.jpg)
java 过滤器filter防sql注入的实现代码
2023-08-30 09:56:40
SpringBoot注册Filter的两种实现方式
2023-01-01 10:26:05
![](https://img.aspxhome.com/file/2023/0/79230_0s.jpg)
Android利用AsyncTask异步类实现网页内容放大缩小
2022-11-28 05:34:47
带你了解Java数据结构和算法之数组
2022-09-29 21:18:33
![](https://img.aspxhome.com/file/2023/7/83087_0s.png)