package com.leon.demo01;import java.util.Collections; import java.util.LinkedList; import java.util.List;/*這是自定義的線程池類;成員變量:1:任務隊列 集合 需要控制線程安全問題2:當前線程數量3:核心線程數量4:最大線程數量5:任務隊列的長度成員方法1:提交任務;將任務添加到集合中,需要判斷是否超出了任務總長度2:執行任務;判斷當前線程的數量,決定創建核心線程還是非核心線程*/ public class MyThreadPool {// 1:任務隊列 集合 需要控制線程安全問題private List<Runnable> tasks = Collections.synchronizedList(new LinkedList<>());//2:當前線程數量private int num;//3:核心線程數量private int corePoolSize;//4:最大線程數量private int maxSize;//5:任務隊列的長度private int workSize;public MyThreadPool(int corePoolSize, int maxSize, int workSize) {this.corePoolSize = corePoolSize;this.maxSize = maxSize;this.workSize = workSize;}//1:提交任務;public void submit(Runnable r){//判斷當前集合中任務的數量,是否超出了最大任務數量if(tasks.size()>=workSize){System.out.println("任務:"+r+"被丟棄了...");}else {tasks.add(r);//執行任務execTask(r);}}//2:執行任務;private void execTask(Runnable r) {//判斷當前線程池中的線程總數量,是否超出了核心數,if(num < corePoolSize){new MyWorker("核心線程:"+num,tasks).start();num++;}else if(num < maxSize){new MyWorker("非核心線程:"+num,tasks).start();num++;}else {System.out.println("任務:"+r+" 被緩存了...");}}} package com.leon.demo01; /*測試類:1: 創建線程池類對象;2: 提交多個任務*/ public class MyTest {public static void main(String[] args) {//1:創建線程池類對象;MyThreadPool pool = new MyThreadPool(2,4,20);//2: 提交多個任務for (int i = 0; i <30 ; i++) {//3:創建任務對象,并提交給線程池MyTask my = new MyTask(i);pool.submit(my);}} }

?

總結

以上是生活随笔為你收集整理的自定义线程池-线程池类和测试类编写的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。