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 秒)
子線程執行順序不能控制,所以輸出的結果是亂序的。