java自定義線程池的原理簡介
更新時間：2019年08月22日 10:09:51 作者：357029540
這篇文章主要介紹了java自定義線程池的原理詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
線程池的相關概念就不在這里說明了，百度一下有很多，這里簡單表述一下如何實現(xiàn)一個自定義的線程池就行線程管理，我們?nèi)绻獙崿F(xiàn)一個線程池對線程的管理，那么需要實現(xiàn)一下幾點的思路:
1.如何管理線程
2.如何定義工作線程以及工作線程如何持續(xù)的保持運行狀態(tài)
3.如何定義線程池大小及隊列大小
4.如何提供接口給調(diào)用者使用
5.如何關閉線程池中的線程
接下來我們就一一的實現(xiàn)這幾個問題。
1.我們需要定義一個隊列來來管理線程，這里使用了LinkedBlockingQueue
// 1.定義一個存儲線程隊列 private LinkedBlockingQueue<Runnable> queue;
2.因為是一個簡單的測試，所以我們可以先定義一個內(nèi)部類來實現(xiàn)工作線程
// 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.使用有參的構(gòu)造方法進行線程池大小的管理
// 3.存放工作線程的集合
private List<Worker> workerList;
// 4.線程池初始化
public SelfThreadPoolExecutor(int coreSize, int queueSize) {
if (coreSize <= 0 || queueSize <= 0) {
throw new IllegalArgumentException("參數(shù)不正確");
}
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();
}
運行結(jié)果是：
準備消費線程 準備消費線程 準備消費線程 準備消費線程 準備消費線程 開啟線程 消費線程 準備消費線程 開啟線程 消費線程 準備消費線程 開啟線程 消費線程 準備消費線程 。。。。。。
以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關文章
這篇文章主要為大家詳細介紹了servlet生命周期的相關資料，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-07-07
下面小編就為大家分享一篇使用MUI框架構(gòu)建App請求http接口實例代碼，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2018-01-01
SpringBoot org.springframework.beans.factory.Unsatisfie
本文主要介紹了SpringBoot org.springframework.beans.factory.UnsatisfiedDependencyException依賴注入異常,文中通過示例代碼介紹的很詳細,具有一定的參考價值,感興趣的可以了解一下2024-02-02
這篇文章主要介紹了Java?Swing實現(xiàn)畫板的簡單操作，修改顏色，更改圖形，清除，任務欄按鈕，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-06-06
springboot @ComponentScan注解原理解析
這篇文章主要介紹了springboot @ComponentScan注解原理解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-02-02
jsoup是一個非常好的解析網(wǎng)頁的包，用java開發(fā)的，提供了類似DOM，CSS選擇器的方式來查找和提取文檔中的內(nèi)容,提取文檔內(nèi)容時會出現(xiàn)超時的情況，解決方法可看下文2013-11-11
SpringCloud中的OpenFeign調(diào)用解讀
OpenFeign是一個顯示聲明式的WebService客戶端,使用OpenFeign能讓編寫Web Service客戶端更加簡單OpenFeign的設計宗旨式簡化Java Http客戶端的開發(fā),本文給大家介紹SpringCloud之OpenFeign調(diào)用解讀,感興趣的朋友一起看看吧2023-11-11
這篇文章主要為大家詳細介紹了Java方法反射的實現(xiàn)原理，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-10-10
這篇文章主要介紹了Java使用新浪微博API通過賬號密碼方式登陸微博的實例,一般來說第三方App都是采用OAuth授權(quán)認證然后跳轉(zhuǎn)之類的方法,而本文所介紹的賬號方式則更具有自由度,需要的朋友可以參考下2016-02-02
這篇文章主要給大家介紹了關于如何利用java控制鼠標操作一些重復的事情,主要利用的是Robot類,Robot可以模擬鼠標和鍵盤的輸入,相當于Java版的按鍵精靈,需要的朋友可以參考下2021-12-12