下面的例子主要討論兩個(gè)問(wèn)題：
問(wèn)題1.線程池固定大小，假設(shè)為5.那么向線程池放入10個(gè)線程，運(yùn)行效果如何？其他線程的狀態(tài)？
問(wèn)題2.那么如何從線程池中移除某一個(gè)線程，確切說(shuō)是使某一個(gè)線程成為空閑線程？

例子：

package com.dada.executorService; 
 
import java.util.concurrent.TimeUnit; 
 
public class JobThread extends Thread { 
  
 // 為線程命名 
 public JobThread(String name,long threadId) { 
  super(name); 
 } 
  
 @Override 
 public void run() { 
  // 如果主線程包含這個(gè)線程就一直運(yùn)行 
  while (MainThread.threadNameMap.containsKey(this.getName())) { 
   try { 
    System.out.println("線程名稱：-----" + this.getName()); 
    TimeUnit.SECONDS.sleep(4); 
   } catch (Exception e) { 
    e.printStackTrace(); 
   } 
  } 
  System.out.println("***************線程結(jié)束，線程名稱：*********" + this.getName()); 
 } 
} 

package com.dada.executorService; 
 
import java.util.HashMap; 
import java.util.Map; 
import java.util.concurrent.ExecutorService; 
import java.util.concurrent.Executors; 
import java.util.concurrent.TimeUnit; 
 
public class MainThread { 
 public static final int THREADPOOL_SIZE = 5; 
 // 生成固定大小的線程池 
 public static ExecutorService exec = Executors.newFixedThreadPool(THREADPOOL_SIZE); 
 // 用來(lái)存儲(chǔ)線程名稱的map 
 public static Map<String, String> threadNameMap = new HashMap<String, String>(); 
  
 public static void main(String[] args) { 
  // 向線程池中插入 10 個(gè)線程，但是線程池只允許最大 5 個(gè)線程，所以其他 5 個(gè)線程等待中 
  for (int i = 0; i < THREADPOOL_SIZE + 5; i++) { 
   String threadName = getThreadName(i); 
   threadNameMap.put(threadName, threadName); 
   exec.execute(new JobThread(threadName, i)); 
  } 
   
  System.out.println("Hash表的Size：" + threadNameMap.size()); 
   
  try { 
   System.out.println("主線程睡一會(huì)！"); 
   TimeUnit.SECONDS.sleep(3); 
  } catch (Exception e) { 
   e.printStackTrace(); 
   System.out.println("醒了！"); 
  } 
   
    // 下面的這幾個(gè)用來(lái)刪除線程池里面的線程 
  //removeThread(0); 
  //removeThread(1); 
  //removeThread(2); 
 } 
  
 public static void removeThread(int i) { 
  threadNameMap.remove(getThreadName(i)); 
  System.out.println("刪除線程Thread" + i + ", Hash表的Size：" + threadNameMap.size()); 
 } 
  
 public static String getThreadName(int i) { 
  return "threadname"+i; 
 } 
  
} 

直接運(yùn)行代碼結(jié)果：

線程名稱：-----threadname0
Hash表的Size：10
主線程睡一會(huì)！
線程名稱：-----threadname2
線程名稱：-----threadname4
線程名稱：-----threadname1
線程名稱：-----threadname3
線程名稱：-----threadname4
線程名稱：-----threadname2
線程名稱：-----threadname3
線程名稱：-----threadname1
線程名稱：-----threadname0
線程名稱：-----threadname1
線程名稱：-----threadname3
線程名稱：-----threadname0
線程名稱：-----threadname4
線程名稱：-----threadname2
線程名稱：-----threadname1
線程名稱：-----threadname3
線程名稱：-----threadname4

結(jié)論：
發(fā)現(xiàn)打印的：線程名稱一直從threadname0到threadname4，沒(méi)有其他的名稱。
由此證明：向線程池中放入10個(gè)線程，但是線程池的大小為5，只能給5個(gè)線程分配CPU，運(yùn)行的就是最先放入線程池中的5個(gè)線程，其他線程都處于就緒狀態(tài)（阻塞狀態(tài)）。

去掉注釋之后代碼運(yùn)行結(jié)果：

線程名稱：-----threadname0
線程名稱：-----threadname2
線程名稱：-----threadname4
Hash表的Size：10
主線程睡一會(huì)！
線程名稱：-----threadname1
線程名稱：-----threadname3
刪除線程Thread0, Hash表的Size：9
刪除線程Thread1, Hash表的Size：8
刪除線程Thread2, Hash表的Size：7
***************線程結(jié)束，線程名稱：*********threadname2
***************線程結(jié)束，線程名稱：*********threadname0
線程名稱：-----threadname5
線程名稱：-----threadname6
***************線程結(jié)束，線程名稱：*********threadname1
線程名稱：-----threadname4
線程名稱：-----threadname7
線程名稱：-----threadname3
線程名稱：-----threadname6
線程名稱：-----threadname5
線程名稱：-----threadname7
線程名稱：-----threadname4
線程名稱：-----threadname3
線程名稱：-----threadname5
線程名稱：-----threadname6
線程名稱：-----threadname7
線程名稱：-----threadname4
線程名稱：-----threadname3

結(jié)論：
從結(jié)果中可以看出，在移除線程之前，運(yùn)行的線程還是從thread0到thread4。當(dāng)移除線程thread0后，新的線程thread3開(kāi)始運(yùn)行，而且是按照順序到threadname7。

總結(jié)如下：

1.線程池固定大小，假設(shè)為5.那么向線程池放入10個(gè)線程，運(yùn)行效果如何？其他線程的狀態(tài)？
a.線程池的概念就是你不斷的向其中push請(qǐng)求，但是它只能處理規(guī)定額度的線程，多余的線程都會(huì)在其中等待。
b.當(dāng)其中一個(gè)線程處理完畢（業(yè)務(wù)執(zhí)行完畢或退出while循環(huán)），線程池就會(huì)自動(dòng)從等待的隊(duì)列中取出一個(gè)作業(yè)，使用空閑的線程來(lái)運(yùn)行這個(gè)作業(yè)。運(yùn)行線程池中的哪個(gè)，從例子上來(lái)看應(yīng)該是按照被放入的先后順序來(lái)的。 

2.那么如何從線程池中移除某一個(gè)線程，確切說(shuō)是使某一個(gè)線程成為空閑線程？
線程池?zé)o法獲取其中某一個(gè)線程并殺掉他，因?yàn)槭褂镁€程池的主線程和主線程開(kāi)啟的線程是平級(jí)的，誰(shuí)都無(wú)權(quán)主宰另一方的存亡。但是可以換一個(gè)方式，委婉的達(dá)到目的。
a.主線程維護(hù)一個(gè)Hash表可以是一個(gè)HashMap。key值任意，但是要唯一，可以唯一標(biāo)示一個(gè)線程。
b.所有放入線程池的線程，都要生成一個(gè)key值，然后存入這個(gè)HashMap中。
c.對(duì)于循環(huán)類的線程，如while(true)的線程。需要增加一個(gè)條件，每一輪循環(huán)校驗(yàn)這個(gè)線程的key是否存在于上面HashMap中。如果不存在則退出while循環(huán)。
d.雖然主線程不可以主宰其他線程的存亡，但是可以對(duì)自己的HashMap進(jìn)行put或是remove操作。到此，只要從HashMap中移除線程對(duì)應(yīng)的Key值，這個(gè)線程在下次循環(huán)的時(shí)候就會(huì)自動(dòng)退出了。

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

最新評(píng)論