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