快捷導(dǎo)航

Java 判斷線程池所有任務(wù)是否執(zhí)行完畢的操作

更新時(shí)間：2020年08月20日 11:35:17 作者：ponhjl

這篇文章主要介紹了Java 判斷線程池所有任務(wù)是否執(zhí)行完畢的操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧

我就廢話不多說了，大家還是直接看代碼吧~

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("結(jié)束了！"); 
        break; 
      } 
      Thread.sleep(200); 
    } 
  } 
}

上面是主線程的代碼，創(chuàng)建了一個(gè)能同時(shí)執(zhí)行2個(gè)線程的線程池，并投入5個(gè)線程，當(dāng)5個(gè)線程都執(zhí)行完畢后打印---“結(jié)束了！”字符串。

exe.shutdown()；該方法在加入線程隊(duì)列的線程執(zhí)行完之前不會(huì)執(zhí)行。exe.isTerminated()當(dāng)shutdown()或者shutdownNow()執(zhí)行了之后才會(huì)執(zhí)行，并返回true。

在上面的代碼中必須有exe.isTerminated()的判斷，否則在投入5個(gè)線程到線程池后會(huì)直接打?。骸敖Y(jié)束了”。不能達(dá)到我們想要的效果。

通過while（true）循環(huán)判斷exe.isTerminated()的值，為了防止過多的判斷浪費(fèi)資源，可設(shè)置線程睡眠Thread.sleep(200);正是由于這個(gè)睡眠，所以當(dāng)所有線程池中的線程都執(zhí)行完后，有可能延遲200ms才執(zhí)行"結(jié)束了"語句。這個(gè)參數(shù)越小延遲越小，結(jié)果越準(zhǔn)確。

下面是子線程，子線程只是簡單的將數(shù)字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); 
  } 
}

執(zhí)行結(jié)果：

3

1

4

5

2

結(jié)束了！

成功構(gòu)建 (總時(shí)間: 2 秒)

子線程執(zhí)行順序不能控制，所以輸出的結(jié)果是亂序的。

補(bǔ)充知識(shí)：java如何禁掉反射

SecurityManager

有一個(gè)checkMemberAccess這個(gè)方法可以阻止利用反射；

如：

SecurityManager sm = new SecurityManager();

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

前面一個(gè)為CLASS，后面需要填一個(gè)INT值，Member.PUBLIC 代表可以訪問，

如果是PUBLIC，反射可以執(zhí)行，DECLARED，反射運(yùn)行時(shí)，會(huì)報(bào)錯(cuò)。

SecurityManager另外一個(gè)例子：

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 判斷線程池所有任務(wù)是否執(zhí)行完畢的操作就是小編分享給大家的全部內(nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: