Java如何判斷線程池所有任務是否執行完畢


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

public class Test {  
    public static void main(String args[]) throws InterruptedException {  
        ExecutorService exe = Executors.newFixedThreadPool(3);  
        for (int i = 1; i <= 5; i++) {  
            exe.execute(new SubThread(i));  
        }  
        exe.shutdown();  
        while (true) {  
            if (exe.isTerminated()) {  
                System.out.println("結束了!");  
                break;  
            }  
            Thread.sleep(200);  
        }  
    }  
}  

上面是主線程的代碼,創建了一個能同時執行2個線程的線程池,並投入5個線程,當5個線程都執行完畢后打印---“結束了!”字符串。
exe.shutdown();該方法在加入線程隊列的線程執行完之前不會執行。exe.isTerminated()當shutdown()或者shutdownNow()執行了之后才會執行,並返回true。
在上面的代碼中必須有exe.isTerminated()的判斷,否則在投入5個線程到線程池后會直接打印:“結束了”。不能達到我們想要的效果。
通過while(true)循環判斷exe.isTerminated()的值,為了防止過多的判斷浪費資源,可設置線程睡眠Thread.sleep(200);正是由於這個睡眠,所以當所有線程池中的線程都執行完后,有可能延遲200ms才執行"結束了"語句。這個參數越小延遲越小,結果越准確。
下面是子線程,子線程只是簡單的將數字i打印出來;

public class SubThread extends Thread{  
    private final int i;  
    public SubThread(int i){  
        this.i = i;  
    }  
    @Override  
    public void run(){  
        System.out.println(i);  
    }  
}  

執行結果:

3  
1  
4  
5  
2  
結束了!  

 

成功構建 (總時間: 2 秒)  
子線程執行順序不能控制,所以輸出的結果是亂序的。

 

轉自:Java如何判斷線程池所有任務是否執行完畢 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM