ExecutorService是java中的一個異步執(zhí)行的框架，通過使用ExecutorService可以方便的創(chuàng)建多線程執(zhí)行環(huán)境。

　　本文將會詳細的講解ExecutorService的具體使用。

　　創(chuàng)建ExecutorService

　　通常來說有兩種方法來創(chuàng)建ExecutorService。

　　第一種方式是使用Executors中的工廠類方法，例如：

　　ExecutorServiceexecutor=Executors.newFixedThreadPool(10);

　　除了newFixedThreadPool方法之外，Executors還包含了很多創(chuàng)建ExecutorService的方法。

　　第二種方法是直接創(chuàng)建一個ExecutorService，因為ExecutorService是一個interface，我們需要實例化ExecutorService的一個實現(xiàn)。

　　這里我們使用ThreadPoolExecutor來舉例：

　　ExecutorServiceexecutorService=

　　newThreadPoolExecutor(1,1,0L,TimeUnit.MILLISECONDS,

　　newLinkedBlockingQueue<Runnable>());

　　為ExecutorService分配Tasks

　　ExecutorService可以執(zhí)行Runnable和Callable的task。其中Runnable是沒有返回值的，而Callable是有返回值的。我們分別看一下兩種情況的使用：

　　RunnablerunnableTask=()->{
　　try{
　　TimeUnit.MILLISECONDS.sleep(300);
　　}catch(InterruptedExceptione){
　　e.printStackTrace();
　　}
　　};
　　Callable<String>callableTask=()->{
　　TimeUnit.MILLISECONDS.sleep(300);
　　return"Task'sexecution";
　　};

　　將task分配給ExecutorService，可以通過調(diào)用xecute(),submit(),invokeAny(),invokeAll()這幾個方法來實現(xiàn)。

　　execute()返回值是void，他用來提交一個Runnabletask。

　　executorService.execute(runnableTask);

　　submit()返回值是Future，它可以提交Runnabletask,也可以提交Callabletask。提交Runnable的有兩個方法：

　　<T>Future<T>submit(Runnabletask,Tresult);

　　Future<?>submit(Runnabletask);

　　第一個方法在返回傳入的result。第二個方法返回null。

　　再看一下callable的使用：

　　Future<String>future=

　　executorService.submit(callableTask);

　　invokeAny()將一個task列表傳遞給executorService，并返回其中的一個成功返回的結(jié)果。

　　Stringresult=executorService.invokeAny(callableTasks);

　　invokeAll()將一個task列表傳遞給executorService，并返回所有成功執(zhí)行的結(jié)果：

　　List<Future<String>>futures=executorService.invokeAll(callableTasks);

　　關(guān)閉ExecutorService

　　如果ExecutorService中的任務運行完畢之后，ExecutorService不會自動關(guān)閉。它會等待接收新的任務。如果需要關(guān)閉ExecutorService，我們需要調(diào)用shutdown()或者shutdownNow()方法。

　　shutdown()會立即銷毀ExecutorService，它會讓ExecutorServic停止接收新的任務，并等待現(xiàn)有任務全部執(zhí)行完畢再銷毀。

　　executorService.shutdown();

　　shutdownNow()并不保證所有的任務都被執(zhí)行完畢，它會返回一個未執(zhí)行任務的列表：

　　List<Runnable>notExecutedTasks=executorService.shutdownNow();

　　oracle推薦的最佳關(guān)閉方法是和awaitTermination一起使用：　

executorService.shutdown();
　　try{
　　if(!executorService.awaitTermination(800,TimeUnit.MILLISECONDS)){
　　executorService.shutdownNow();
　　}
　　}catch(InterruptedExceptione){
　　executorService.shutdownNow();
　　}

先停止接收任務，然后再等待一定的時間讓所有的任務都執(zhí)行完畢，如果超過了給定的時間，則立刻結(jié)束任務。

　　Future

　　submit()和invokeAll()都會返回Future對象。之前的文章我們已經(jīng)詳細講過了Future。這里就只列舉一下怎么使用：

　　Future<String>future=executorService.submit(callableTask);

　　Stringresult=null;

　　try{

　　result=future.get();

　　}catch(InterruptedException|ExecutionExceptione){

　　e.printStackTrace();

　　}

　　ScheduledExecutorService

　　ScheduledExecutorService為我們提供了定時執(zhí)行任務的機制。

　　我們這樣創(chuàng)建ScheduledExecutorService：

　　ScheduledExecutorServiceexecutorService

　　=Executors.newSingleThreadScheduledExecutor();

　　executorService的schedule方法，可以傳入Runnable也可以傳入Callable：

　　Future<String>future=executorService.schedule(()->{

　　//...

　　return"Helloworld";

　　},1,TimeUnit.SECONDS);

　　ScheduledFuture<?>scheduledFuture=executorService.schedule(()->{

　　//...

　　},1,TimeUnit.SECONDS);

　　還有兩個比較相近的方法：

　　scheduleAtFixedRate(Runnablecommand,longinitialDelay,longperiod,TimeUnitunit)

　　scheduleWithFixedDelay(Runnablecommand,longinitialDelay,longdelay,TimeUnitunit)

　　兩者的區(qū)別是前者的period是以任務開始時間來計算的，后者是以任務結(jié)束時間來計算。

　　ExecutorService和Fork/Join

　　java7引入了Fork/Join框架。那么兩者的區(qū)別是什么呢？

　　ExecutorService可以由用戶來自己控制生成的線程，提供了對線程更加細粒度的控制。而Fork/Join則是為了讓任務更加快速的執(zhí)行完畢。

　　以上就是動力節(jié)點java培訓機構(gòu)的小編針對“Java高級架構(gòu)師視頻教程，ExecutorService的使用”的內(nèi)容進行的回答，希望對大家有所幫助，如有疑問，請在線咨詢，有專業(yè)老師隨時為你服務。