本文實(shí)例為大家分享了Java簡(jiǎn)單實(shí)現(xiàn)線程池的具體代碼，供大家參考，具體內(nèi)容如下

線程池是一種緩沖提高效率的技術(shù)。相當(dāng)于一個(gè)池子，里面存放大量已經(jīng)創(chuàng)建好的線程，當(dāng)有一個(gè)任務(wù)需要處理時(shí)， 可以直接從池子里面取一個(gè)線程去執(zhí)行它。 包括內(nèi)存池，很多緩沖的技術(shù)都是采用這種技術(shù)。 其實(shí)理解起來很簡(jiǎn)答！

為什么需要線程池，這種池的技術(shù)？

1.1 減少開辟資源和銷毀資源帶來的損耗。

開辟線程，申請(qǐng)內(nèi)存（具體的可以看C語言中malloc底層實(shí)現(xiàn)原理），銷毀線程、釋放內(nèi)存資源等一些操作都是有時(shí)間消耗的。因此一開始開辟大量的資源進(jìn)行管理，需要使用時(shí)從池中取一個(gè)去使用， 使用完畢后再放回池中管理， 這樣可以避免資源開辟和銷毀帶來的時(shí)間損耗。

1.2 提高響應(yīng)。

用戶來了一個(gè)請(qǐng)求， 能夠立刻從開辟好的線程池中取一個(gè)線程去處理執(zhí)行。 提高響應(yīng)效率，提高用戶體驗(yàn)。

1.3 有效管理資源

管理資源統(tǒng)一開辟和銷毀， 監(jiān)控線程狀態(tài)和調(diào)優(yōu)

對(duì)于線程池的實(shí)現(xiàn)我們劃分為2個(gè)部分

1、線程安全的任務(wù)隊(duì)列（采用隊(duì)列，不過是線程安全的而已），保證工作線程在去任務(wù)時(shí)不會(huì)發(fā)生沖突（重復(fù)取同一個(gè)任務(wù)處理，二次執(zhí)行或者多次的問題）。2、對(duì)工作線程的監(jiān)管（采用是List管理工作線程），方便線程的銷毀和管理。

線程池處理邏輯：

1、每當(dāng)添加一個(gè)任務(wù)，就會(huì)從線程池中取一個(gè)工作線程去處理執(zhí)行它。2、沒有任務(wù)處理時(shí)， 工作線程應(yīng)該處于阻塞狀態(tài)等待任務(wù)到來， 不會(huì)競(jìng)爭(zhēng)占用CPU資源3、線程池相當(dāng)于生產(chǎn)-消費(fèi)模型， 只不過生產(chǎn)線程的中生產(chǎn)任務(wù)不同罷了。

3、主線程相當(dāng)于監(jiān)管線程，最終負(fù)責(zé)工作線程的銷毀。

1、 工作線程Worker

1.1、工作線程負(fù)責(zé)從阻塞任務(wù)隊(duì)列中取出任務(wù)執(zhí)行。由于存在很多個(gè)線程對(duì)同一個(gè)隊(duì)列操作，因此這個(gè)任務(wù)隊(duì)列一定得是線程安全的（采用BlockingQueue接口， 這是GUC提供的，線程安全）1.2、工作線程的創(chuàng)建方式屬于線程創(chuàng)建的方式之一。1.3、每個(gè)工作線程都維護(hù)一個(gè)阻塞任務(wù)隊(duì)列。1.4、線程的執(zhí)行方法run()中，以線程的中斷狀態(tài)為循環(huán)判斷條件（方便線程銷毀， 只要將工作線程的中斷狀態(tài)置為true即可釋放工作線程）其次就是BlockingQueue接口提供的take()方法。

該方法在隊(duì)列沒有元素時(shí)處于阻塞狀態(tài)，直接取到元素，這樣就解決了沒有任務(wù)工作線程處于阻塞狀態(tài)，不會(huì)搶占CPU

//實(shí)現(xiàn)工作線程 - 工作線程中維護(hù)了公有的任務(wù)隊(duì)列（阻塞）, 工作線程的執(zhí)行邏輯。 循環(huán)取隊(duì)列中的任務(wù)去執(zhí)行處理。class Worker extends Thread { //阻塞任務(wù)隊(duì)列 - 可以保證多個(gè)線程對(duì)隊(duì)列操作， 線程安全 private BlockingQueue<Runnable> queue = null; //每個(gè)工作線程都會(huì)有一個(gè)阻塞隊(duì)列，這個(gè)隊(duì)列中保存了所有的任務(wù) public Worker(BlockingQueue<Runnable> queue, int id) {this.queue = queue; // Thread.currentThread().setName('郝夢(mèng)武' + id + '號(hào)工作線程'); }//工作線程執(zhí)行內(nèi)容 @Override public void run() {//每個(gè)線程通過isInterrupted()判斷線程異常狀態(tài)。try { while (!Thread.currentThread().isInterrupted()) {//如果線程正常， 返回false, 出現(xiàn)異常， 返回true， 該狀態(tài)默認(rèn)為falseRunnable command = queue.take(); //如果隊(duì)列為空， take會(huì)讓線程阻塞System.out.println(Thread.currentThread().getName() + '正在處理任務(wù)' + command.hashCode());command.run(); }}catch(InterruptedException e) { System.out.println(Thread.currentThread().getName() + '被中止了');// e.printStackTrace(); //不需要拋出異常} }}

2、線程池對(duì)象MyThreadPool

1、創(chuàng)建工作線程并管理，添加任務(wù)。2、銷毀所有工作線程

//線程池 - 維護(hù)很多個(gè)線程， 當(dāng)來一個(gè)任務(wù)時(shí)， 從線程池中獲取一個(gè)線程去處理執(zhí)行。//好處： 防止線程頻繁開辟和銷毀帶來的性能損耗class MyThreadPool { //創(chuàng)建任務(wù)線程安全的隊(duì)列, 保證多個(gè)線程對(duì)這個(gè)隊(duì)列操作時(shí)是線程安全的 private BlockingQueue<Runnable> queue = new LinkedBlockingQueue<>(); //線程管理列表 - 這個(gè)列表保存了所有線程對(duì)象的引用， 方便后續(xù)的管理 private List<Worker> Wokers = new ArrayList<>(); private final static int maxWorkerCount = 10; //線程池最大允許的個(gè)數(shù) //execute方法 public void execute(Runnable command) throws InterruptedException {if(Wokers.size() < maxWorkerCount) { //創(chuàng)建一個(gè)新的工作線程 Worker worker = new Worker(queue, Wokers.size()); //創(chuàng)建工作線程 worker.start(); //創(chuàng)建的工程線程啟動(dòng) Wokers.add(worker); //添加到管理列表中}queue.put(command); //添加任務(wù)到線程安全的隊(duì)列中 } //銷毀所有線程 - 將每個(gè)線程中狀態(tài)置為中斷狀態(tài)方法， 并且 public void shutDown() throws InterruptedException {for(Worker worker : Wokers) { worker.interrupt(); //將線程的狀態(tài)置為中斷， 調(diào)用isInterruptd()返回值為true}//并且讓主線程join阻塞等待所有工作線程for(Worker worker : Wokers) { worker.join(); //join方法可以讓調(diào)用的線程處于阻塞狀態(tài)， 知道等待的線程結(jié)束完畢之后就會(huì)恢復(fù)}//執(zhí)行到這塊， 代表所有的線程銷毀完畢System.out.println('所有工作線程銷毀完畢!'); }}

3、測(cè)試代碼

class MyRunnable implements Runnable { private int num; MyRunnable(int num) {this.num = num; } @Override public void run() {System.out.println('正在執(zhí)行任務(wù): ' + num); }}public static void main(String[] args) throws InterruptedException { MyThreadPool myThreadPool = new MyThreadPool(); for(int i = 0; i < 1000; i++) { myThreadPool.execute(new MyRunnable(i + 1)); } Thread.sleep(2000); //主線程休眠2s myThreadPool.shutDown(); //銷毀所有工作線程 System.out.println('線程池已經(jīng)被銷毀了'); }

4、測(cè)試結(jié)果

總結(jié)：

以上的代碼只是簡(jiǎn)單模擬實(shí)現(xiàn)了線程池。不僅僅是線程池，內(nèi)容池，還有很多池的應(yīng)用場(chǎng)景。池的技術(shù)雖然能夠起到快速響應(yīng)的特點(diǎn)，但是還是存在問題。第一點(diǎn)： 池需要在一開始創(chuàng)建很多資源， 這和我們機(jī)器內(nèi)存大小有關(guān)系。第二點(diǎn)： 池中的線程過多，但是任務(wù)過少，導(dǎo)致很多線程浪費(fèi)掉， 因此池中開辟多大的資源需要根據(jù)實(shí)際情況而言。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持好吧啦網(wǎng)。