代码之家 › 专栏 › 技术社区 › Frank Kong

Java中关闭ExecutorService的最佳方法

multithreading java

Frank Kong · 技术社区 · 6 年前

这是我的原始代码:

ExecutorService executorService = Executors.newFixedThreadPool(10);

Future<String> f = executorService.submit(() -> {/*do something*/});

executorService.shutdown();

String result = f.get();
System.out.println(result);

f.get() 永远持续,程序将永远停止,永不退出。

带着担心,下面是我的第二次尝试:

ExecutorService executorService = Executors.newFixedThreadPool(10);

Future<String> f = executorService.submit(() -> {/*do something*/});

executorService.shutdown();

if(!executorService.awaitTermination(10, TimeUnit.SECONDS)){
    executorService.shutdownNow();
}

String result = f.get();
System.out.println(result);

我的问题是如何设置强制关闭池中线程的时间,以便不必显式使用 awaitTermination 阻止程序。

3 回复 | 直到 6 年前

Malt 6 年前

但是我担心如果写错了代码怎么办出口。

使用上面的代码,我可以确保线程在10秒后关闭

shutdownNow() 实际上并不能保证执行器线程被关闭( documentation ):

除了尽最大努力停止处理之外,没有任何保证积极执行任务。例如,典型的实现将中断可能永远不会终止。

这个 ThreadPoolExecutor handle interrupts correctly .

一旦任务正确停止,就可以根据应用程序和要关闭的任务估计关闭所需的时间。然后您可以正常关机:

shutdown()
在合理的时间内等待有序关机 awaitShutdown()
如果执行器仍在运行,请调用并处理它返回的任何未完成任务。

Dinesh 6 年前

/** *阻塞,直到关闭后所有任务都已完成执行 *中断,以先发生者为准。 * *@param unit超时参数的时间单位 *{@code false}如果在终止前超时已过

Shivang Agarwal 6 年前

除了上述答案外,我还想补充以下几点。

isDone() 在调用get()方法以验证任务是否在通过ExcuterService api的awaitTermination方法等待任务完成时完成。

但是我建议你现在可以用

给定计算完成的时间,然后检索结果,如有。]

未来的API。会的 .

isShutdown() ExecuterService API的方法。

推荐文章

Zdanovskiy Mihail · Numba使用parallel=True标志集使Python崩溃

1 年前

Ma Joonyoung · 粗粒度和细粒度链表的时间比较

1 年前

Community wiki · SqlConnections,Parallel.For,一个旧的C#应用程序,初始化SqlConnections时随机挂起

1 年前

user1700890 · 了解交互式代理Python API中的线程

2 年前

AntonBoarf · 为什么要将实例变量指定给局部变量?

2 年前

rhymes · 如何让线程操作相同的java列表

2 年前

Ben · 错误:缺少类型说明符-假定为int。注意C++不支持默认初始化

2 年前

SRK7Kyros · 在Python中启动线程时是否使用整个处理器线程?

2 年前

MatiiFine · 在c++[duplicate]中的主源文件外使用std::thread

2 年前

Youssof. K. · 线程1:vector insert上的EXC_BAD_访问(代码=1,地址=0x0)

2 年前