java自定義線程池的原理簡介
更新時間：2019年08月22日 10:09:51 作者：357029540
這篇文章主要介紹了java自定義線程池的原理詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
線程池的相關概念就不在這里說明了，百度一下有很多，這里簡單表述一下如何實現一個自定義的線程池就行線程管理，我們如果要實現一個線程池對線程的管理，那么需要實現一下幾點的思路:
1.如何管理線程
2.如何定義工作線程以及工作線程如何持續(xù)的保持運行狀態(tài)
3.如何定義線程池大小及隊列大小
4.如何提供接口給調用者使用
5.如何關閉線程池中的線程
接下來我們就一一的實現這幾個問題。
1.我們需要定義一個隊列來來管理線程，這里使用了LinkedBlockingQueue
// 1.定義一個存儲線程隊列 private LinkedBlockingQueue<Runnable> queue;
2.因為是一個簡單的測試，所以我們可以先定義一個內部類來實現工作線程
// 2.定義工作線程進行線程的執(zhí)行
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實現五子棋大戰(zhàn)，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-03-03
Redisson是一個在Redis的基礎上實現的Java駐內存數據網格（In-Memory?Data?Grid）。Redisson有一樣功能是可重入的分布式鎖。本文來討論一下這個功能的特點以及源碼分析2022-11-11
java序列化對象根據不同配置動態(tài)改變屬性名的方法
本文主要介紹了java序列化對象根據不同配置動態(tài)改變屬性名的方法，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下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