1. 程式人生 > 程式設計 >Java 判斷執行緒池所有任務是否執行完畢的操作

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如何禁掉反射

SecurityManager

有一個checkMemberAccess這個方法可以阻止利用反射;

如:

SecurityManager sm = new SecurityManager();

sm.checkMemberAccess(Test.class,Member.PUBLIC);

前面一個為CLASS,後面需要填一個INT值,Member.PUBLIC 代表可以訪問,

如果是PUBLIC,反射可以執行,DECLARED,反射執行時,會報錯。

SecurityManager另外一個例子:

package com.jd.basic.pk.manager;
import java.lang.reflect.Field;
import java.security.Permission;

public class UseReflection {
  static {
    try {
      System.setSecurityManager(new MySecurityManager());
    } catch (SecurityException se) {
      System.out.println("SecurityManager already set!");
    }
  }

  public static void main(String args[]) {
    Object prey = new Prey();
    try {
      Field pf = prey.getClass().getDeclaredField("privateString");
      pf.setAccessible(true);
      pf.set(prey,"Aminur test");
      System.out.println(pf.get(prey));
    } catch (Exception e) {
      System.err.println("Caught exception " + e.toString());
    }
  }
}

class Prey {
  @SuppressWarnings("unused")
  private String privateString = "privateValue";
}

class MySecurityManager extends SecurityManager {
  public void checkPermission(Permission perm) {
    if (perm.getName().equals("suppressAccessChecks")) {
      throw new SecurityException("Can not change the permission dude.!");
    }
  }
}

以上這篇Java 判斷執行緒池所有任務是否執行完畢的操作就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支援我們。