Java 判断线程池所有任务是否执行完毕的操作

2025-05-29 0 97

我就废话不多说了,大家还是直接看代码吧~

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19
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打印出来;

?

1

2

3

4

5

6

7

8

9

10
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另外一个例子:

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38
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 判断线程池所有任务是否执行完毕的操作就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持快网idc。

原文链接:http://blog.chinaunix.net/uid-29368697-id-4065665.html

收藏 (0) 打赏

感谢您的支持,我会继续努力的!

打开微信/支付宝扫一扫,即可进行扫码打赏哦,分享从这里开始,精彩与您同在
点赞 (0)

声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。

快网idc优惠网 建站教程 Java 判断线程池所有任务是否执行完毕的操作 https://www.kuaiidc.com/118648.html

相关文章

发表评论
暂无评论