Executor之isTerminated && awaitTermination

Executor之isTerminated && awaitTermination

在這篇文章http://my.oschina.net/xinxingegeya/blog/219372#OSC_h2_8裏說到了Executor的生命週期。

當提交了任務後，有時咱們須要等待全部提交的任務的執行完成，而後才能繼續下面的邏輯。那麼如何來等待全部提交的任務執行完成呢？

Executor提供了一下幾個方法，（方法詳細說明見api文檔）

shutdown 方法將執行平緩的關閉過程：不在接受新的任務，同時等待已經提交的任務執行完成---包括那些還未開始執行的任務。

shutdownNow 方法將執行粗暴的關閉過程：他將嘗試取消全部運行中的任務，而且再也不啓動隊列中還沒有開始執行的任務。

isShutdown 判斷以前是否調用過shutdown

isTerminated 判斷全部提交的任務是否完成（保證以前調用過shutdown方法）

awaitTermination 調用shutdown方法後，等待全部任務執行完成

咱們就是使用這幾個方法來判斷提交的任務是否完成，以下代碼所示，

package com.usoft;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

/**
 * @author: Lenovo(2015-06-30 20:17)
 */
public class Hello {

    public static void main(String args[]) throws InterruptedException {
        ExecutorService pool = Executors.newFixedThreadPool(5);
        for (int i = 0; i < 10; i++) {
            pool.submit(new Runnable() {
                @Override
                public void run() {
                    try {
                        Thread.sleep(5000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println("runnable complete...");
                }
            });
        }

        pool.shutdown();
        System.out.println("pool shutdown:" + pool.isShutdown());
        while (!pool.isTerminated()) {
            pool.awaitTermination(1, TimeUnit.SECONDS);
        }

        System.out.println("all task complete");
    }
}

================END================