資源描述:
《java并發(fā)編程(19):并發(fā)新特性—executor框架與線程池(含代碼)-編程開發(fā)技術(shù)》由會員上傳分享,免費(fèi)在線閱讀,更多相關(guān)內(nèi)容在工程資料-天天文庫。
1、hva并發(fā)編程(19):并發(fā)新特性一Executor框架與線程池(含代碼)-編程開發(fā)技術(shù)Java并發(fā)編程(19):并發(fā)新特性—Executor框架與線程池(含代碼)原文岀處:蘭亭風(fēng)雨Executor框架簡介在Java5之后,并發(fā)編程引入了一堆新的啟動、調(diào)度和管理線程的APToExecutor框架便是Java5中引入的,其內(nèi)部使用了線程池機(jī)制,它在java.util,cocurrent包下,通過該框架來控制線程的啟動、執(zhí)行和關(guān)閉,可以簡化并發(fā)編程的操作。因此,在Java5之后,通過Executor來啟動線程比使
2、用Thread的start方法更好,除了更易管理,效率更好(用線程池實(shí)現(xiàn),節(jié)約開銷)夕卜,還有關(guān)鍵的一點(diǎn):有助于避免this逃逸問題一一如果我們在構(gòu)造器中啟動一個線程,因?yàn)榱硪粋€任務(wù)可能會在構(gòu)造器結(jié)束之前開始執(zhí)行,此時可能會訪問到初始化了一半的對彖用Executor在構(gòu)造器小。Executor框架包括:線程池,Executor,Executors,ExecutorService,CompletionService,Future,Callable等。Executor接口中之定義了一個方法execute(Runn
3、ablecommand),該方法接收一個Runable實(shí)例,它用來執(zhí)行一個任務(wù),任務(wù)即一個實(shí)現(xiàn)了Runnable接口的類。ExccutorScrvicc接II繼承口Executor接II,它提供了更豐富的實(shí)現(xiàn)多線程的方法,比如,ExecutorService捉供了關(guān)閉自己的方法,以及可為跟蹤一個或多個異步任務(wù)執(zhí)彳亍狀況而生成Future的方法??梢哉{(diào)用ExecutorService的shutdown()方法來平滑地關(guān)閉ExecutorService,調(diào)用該方法后,將導(dǎo)致ExecutorService停止接受任
4、何新的任務(wù)且等待已經(jīng)提交的任務(wù)執(zhí)行完成(已經(jīng)提交的任務(wù)會分兩類:一類是已經(jīng)在執(zhí)行的,另一類是還沒有開始執(zhí)行的),當(dāng)所冇已經(jīng)捉交的任務(wù)執(zhí)行完畢后將會關(guān)閉ExecutorService。因此我們一般用該接口來實(shí)現(xiàn)和管理多線程。ExecutorService的生命周期包括三種狀態(tài):運(yùn)行、關(guān)閉、終止。創(chuàng)建后便進(jìn)入運(yùn)行狀態(tài),當(dāng)調(diào)用了shutdown()方法時,便進(jìn)入關(guān)閉狀態(tài),此時意味著ExccutorScrvicc不再接受新的任務(wù),但它述在執(zhí)行已經(jīng)提交了的任務(wù),當(dāng)素有已經(jīng)提交了的任務(wù)執(zhí)行完后,便到達(dá)終止?fàn)顟B(tài)。如果不調(diào)用
5、shutdown()方法,ExecutorService會一直處在運(yùn)行狀態(tài),不斷接收新的任務(wù),執(zhí)行新的任務(wù),服務(wù)器端一般不需要關(guān)閉它,保持一一直運(yùn)行即可。Executors提供了一系列工廠方法用于創(chuàng)先線程池,返回的線程池都實(shí)現(xiàn)了ExccutorScrvicc接口。publicstaticExecutorServicenewFixedThreadPool(intnThreads)創(chuàng)建固定數(shù)目線程的線程池。publicstaticExecutorServicenewCachedThreadPool()創(chuàng)建一個可緩
6、存的線程池,調(diào)用execute將重用以前構(gòu)造的線程(如果線程可用)。如果現(xiàn)有線程沒有可用的,則創(chuàng)建一個新線?程并添加到池中。終止并從緩存屮移除那些已冇60秒鐘未被使用的線程。publicstaticExecutorServicenewSingleThreadExecutor()創(chuàng)建一個單-線程化的ExecutoPopublicstaticScheduledExecutorServicenewScheduledThreadPool(intcorePoolSize)創(chuàng)建一個支持定時及周期性的任務(wù)執(zhí)行的線程池,多數(shù)
7、情況下可用來替代Timer類。這四種方法都是用的Executors中的ThreadFactory建立的線程,下面就以上四個方法做個比較newCachedThreadPool()?????????????????????????????????9?999??9?9?99?999999?999999?99999999■緩存型池子,先查看池中冇沒有以前建立的線程,如果冇,就reuse.如果沒有,就建一個新的線程加入池中■緩存型池了通常用于執(zhí)行一些生存期很短的界步型任務(wù)因此在一些面向連接的daemon型SERVER中
8、用得不多。但對于牛?存期短的異步任務(wù),它是Executor的首選。-能reuse的線程,必須是timeoutIDLE內(nèi)的池中線程,缺????timeout是60s,超過這個IDLE時長,線程實(shí)例將被終止及移出池。?注意,放入CachedThreadPool的線程不必?fù)?dān)心-K結(jié)束,超過TIMEOUT不活動,其會H動被終止。newFixedThreadPool(int)-newFixedThreadPoo