下面的例子主要討論兩個問題:
問題1.線程池固定大小,假設(shè)為5.那么向線程池放入10個線程,運行效果如何?其他線程的狀態(tài)?
問題2.那么如何從線程池中移除某一個線程,確切說是使某一個線程成為空閑線程?
例子:
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() {   // 如果主線程包含這個線程就一直運行   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);  // 用來存儲線程名稱的map  public static Map<String, String> threadNameMap = new HashMap<String, String>();    public static void main(String[] args) {   // 向線程池中插入 10 個線程,但是線程池只允許最大 5 個線程,所以其他 5 個線程等待中   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("主線程睡一會!");    TimeUnit.SECONDS.sleep(3);   } catch (Exception e) {    e.printStackTrace();    System.out.println("醒了!");   }        // 下面的這幾個用來刪除線程池里面的線程   //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;  }   } 直接運行代碼結(jié)果:
線程名稱:-----threadname0
Hash表的Size:10
主線程睡一會!
線程名稱:-----threadname2
線程名稱:-----threadname4
線程名稱:-----threadname1
線程名稱:-----threadname3
線程名稱:-----threadname4
線程名稱:-----threadname2
線程名稱:-----threadname3
線程名稱:-----threadname1
線程名稱:-----threadname0
線程名稱:-----threadname1
線程名稱:-----threadname3
線程名稱:-----threadname0
線程名稱:-----threadname4
線程名稱:-----threadname2
線程名稱:-----threadname1
線程名稱:-----threadname3
線程名稱:-----threadname4
結(jié)論:
發(fā)現(xiàn)打印的:線程名稱一直從threadname0到threadname4,沒有其他的名稱。
由此證明:向線程池中放入10個線程,但是線程池的大小為5,只能給5個線程分配CPU,運行的就是最先放入線程池中的5個線程,其他線程都處于就緒狀態(tài)(阻塞狀態(tài))。
去掉注釋之后代碼運行結(jié)果:
線程名稱:-----threadname0
線程名稱:-----threadname2
線程名稱:-----threadname4
Hash表的Size:10
主線程睡一會!
線程名稱:-----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é)果中可以看出,在移除線程之前,運行的線程還是從thread0到thread4。當(dāng)移除線程thread0后,新的線程thread3開始運行,而且是按照順序到threadname7。
總結(jié)如下:
1.線程池固定大小,假設(shè)為5.那么向線程池放入10個線程,運行效果如何?其他線程的狀態(tài)?
a.線程池的概念就是你不斷的向其中push請求,但是它只能處理規(guī)定額度的線程,多余的線程都會在其中等待。
b.當(dāng)其中一個線程處理完畢(業(yè)務(wù)執(zhí)行完畢或退出while循環(huán)),線程池就會自動從等待的隊列中取出一個作業(yè),使用空閑的線程來運行這個作業(yè)。運行線程池中的哪個,從例子上來看應(yīng)該是按照被放入的先后順序來的。 
2.那么如何從線程池中移除某一個線程,確切說是使某一個線程成為空閑線程?
線程池?zé)o法獲取其中某一個線程并殺掉他,因為使用線程池的主線程和主線程開啟的線程是平級的,誰都無權(quán)主宰另一方的存亡。但是可以換一個方式,委婉的達(dá)到目的。
a.主線程維護(hù)一個Hash表可以是一個HashMap。key值任意,但是要唯一,可以唯一標(biāo)示一個線程。
b.所有放入線程池的線程,都要生成一個key值,然后存入這個HashMap中。
c.對于循環(huán)類的線程,如while(true)的線程。需要增加一個條件,每一輪循環(huán)校驗這個線程的key是否存在于上面HashMap中。如果不存在則退出while循環(huán)。
d.雖然主線程不可以主宰其他線程的存亡,但是可以對自己的HashMap進(jìn)行put或是remove操作。到此,只要從HashMap中移除線程對應(yīng)的Key值,這個線程在下次循環(huán)的時候就會自動退出了。
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持武林網(wǎng)。
新聞熱點
疑難解答
圖片精選