天天看點

java使用Executor(執行器)管理線程

<a></a>

  CacheThreadPool會為每一個任務建立一個線程。非常常見的情況是,單個的Executor被用來建立和管理系統中的任務。shutdown()方法可以防止新的任務被送出給這個Executor。如果在shutdown()方法之後送出新任務,則會抛出java.util.concurrent.RejectedExecutionException異常。

  FixedThreadPool使用了優先的線程集來執行所送出的任務。有了它,你就可以一次性預先執行代價高的線程配置設定。也就是說如果設定的最大線程數量是x,而送出的線程數y,那麼(y-x)對應的這些線程要等到前x個線程執行完畢才會執行。

  下面的例子中,線程6一直不會有機會執行。因為run()方法中是 while(true), 可以将while(true)去掉,前5個線程執行完畢後,才會執行第6個線程。

  SingleThreadExecutor就像是線程數量為1的FixedThreadPool。這對于你希望在另一個線程中連續運作的事物(長期存活的任務)來說,都是很有用的。如果想SingleThreadExecutor送出了多個任務,那麼這些任務将排隊,每個任務都會在下一個任務開始之前結束,所有的任務将使用相同的線程。

  submit()會産生Future對象,它用Callable傳回結果的特定類型進行了參數化。可以調用Future的isDone()方法來查詢Future是否已經完成。調用Future的get()方法來擷取最終線程的執行結果。另外,Future的get()方法是一個阻塞方法,直到結果準備就緒。

  volatile變量保證編譯器對循環不進行任何的優化,如果不加入這些運算的話,就不會看到設定線程優先級的效果。數學運算是可以中斷的,向控制台列印不能被中斷。這裡預案算時間足夠的長,是以線程排程機制才來的及介入,交換任務并關注優先級,是的最高優先級被優先選擇。

  所謂背景線程,是指程式運作的時候在背景提供一種通用的服務的線程,并且這種線程并不屬于程式中不可或缺的部分。是以,當所有的非背景線程結束時,程式也就終止了,同時會殺死程序中的所有的背景線程。反過來說,隻要任何非背景線程還在運作,程式就不會終止。

  通過定制自己的ThreadFactory, 可以定制有Executor建立的線程的屬性(背景,優先級,名稱)

本文轉自 小眼兒 部落格園部落格,原文連結:http://www.cnblogs.com/hujunzheng/p/5097470.html,如需轉載請自行聯系原作者