java自定义线程池的原理简介
更新时间：2019年08月22日 10:09:51 作者：357029540
这篇文章主要介绍了java自定义线程池的原理详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
线程池的相关概念就不在这里说明了，百度一下有很多，这里简单表述一下如何实现一个自定义的线程池就行线程管理，我们如果要实现一个线程池对线程的管理，那么需要实现一下几点的思路:
1.如何管理线程
2.如何定义工作线程以及工作线程如何持续的保持运行状态
3.如何定义线程池大小及队列大小
4.如何提供接口给调用者使用
5.如何关闭线程池中的线程
接下来我们就一一的实现这几个问题。
1.我们需要定义一个队列来来管理线程，这里使用了LinkedBlockingQueue
// 1.定义一个存储线程队列 private LinkedBlockingQueue<Runnable> queue;
2.因为是一个简单的测试，所以我们可以先定义一个内部类来实现工作线程
// 2.定义工作线程进行线程的执行
class Worker extends Thread {
private SelfThreadPoolExecutor threadPoolExecutor;
public Worker(SelfThreadPoolExecutor poolExecutor) {
this.threadPoolExecutor = poolExecutor;
}
@Override
public void run() {
Runnable task;
while (threadPoolExecutor.receiveTask || threadPoolExecutor.queue.size() > 0) {
try {
// 有线程则取出来，否则等待
System.out.println("准备消费线程");
task = threadPoolExecutor.queue.take();
if (task != null) {
task.run();
System.out.println("消费线程");
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
SelfThreadPoolExecutor是外部定义的整体类名
3.使用有参的构造方法进行线程池大小的管理
// 3.存放工作线程的集合
private List<Worker> workerList;
// 4.线程池初始化
public SelfThreadPoolExecutor(int coreSize, int queueSize) {
if (coreSize <= 0 || queueSize <= 0) {
throw new IllegalArgumentException("参数不正确");
}
this.queue = new LinkedBlockingQueue<>(queueSize);
// 线程安全的集合
this.workerList = Collections.synchronizedList(new ArrayList<>());
for (int i = 0; i < coreSize; i++) {
Worker worker = new Worker(this);
worker.start();
workerList.add(worker);
}
}
4.定义阻塞和非阻塞的方式提供对应的接口
// 5.非阻塞的方法接口
public boolean offer(Runnable task) {
if (receiveTask) {
return queue.offer(task);
} else {
return false;
}
}
// 6.阻塞的方法接口
public void put(Runnable task) {
try {
if (receiveTask) {
queue.put(task);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
6.进行线程池的关闭
// 7.线程池的关闭
private boolean receiveTask = true;
public void shutdown() {
// 7.1.队列不再接收线程
receiveTask = false;
// 7.2.关闭处于wait或block的线程
for (Thread thread : workerList) {
if (Thread.State.BLOCKED.equals(thread.getState())
|| Thread.State.WAITING.equals(thread.getState())
|| Thread.State.TIMED_WAITING.equals(thread.getState())){
thread.interrupt();
}
}
}
我们测试的方法如下：
public static void main(String [] args){
SelfThreadPoolExecutor selfThreadPoolExecutor = new SelfThreadPoolExecutor(5,10);
for(int i = 0;i < 20;i++){
Runnable task = () ->{
System.out.println("开启线程");
};
selfThreadPoolExecutor.put(task);
}
selfThreadPoolExecutor.shutdown();
}
运行结果是：
准备消费线程 准备消费线程 准备消费线程 准备消费线程 准备消费线程 开启线程 消费线程 准备消费线程 开启线程 消费线程 准备消费线程 开启线程 消费线程 准备消费线程 。。。。。。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了java实现快速排序的方法,涉及java排序的相关操作技巧,需要的朋友可以参考下2015-05-05
这篇文章主要为大家详细介绍了java实现五子棋大战，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-03-03
Redisson是一个在Redis的基础上实现的Java驻内存数据网格（In-Memory Data Grid）。Redisson有一样功能是可重入的分布式锁。本文来讨论一下这个功能的特点以及源码分析2022-11-11
本文主要介绍了java序列化对象根据不同配置动态改变属性名的方法，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-05-05
这篇文章主要为大家详细介绍了Java实现简易计算器，逆波兰表达式，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-07-07
这篇文章主要介绍了java取两个字符串的最大交集的方法,涉及Java对字符串操作的技巧,具有一定的参考借鉴价值,需要的朋友可以参考下2014-10-10
这篇文章主要介绍了Spring Boot加密配置文件特殊内容的相关知识，本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2020-05-05
这篇文章主要介绍了java 使用策略模式操作JDBC数据库的相关资料,这里提供实例实现对JDBC数据库的操作增删改查的功能，需要的朋友可以参考下2017-08-08
这篇文章主要给大家介绍了关于Java中四种线程池的使用方法，四种线程池分别包括FixedThreadPool、CachedThreadPool、ScheduledThreadPool以及SingleThreadExecutor，文中给出了详细的示例代码供大家参考，需要的朋友们下面来一起看看吧。2017-08-08
SpringBoot整合RabbitMQ实现交换机与队列的绑定
这篇文章将通过几个实例为大家介绍一些SpringBoot中RabbitMQ如何绑定交换机（交换器）与队列，文中的示例代码讲解详细，感兴趣的可以了解一下2022-05-05
最新评论