问题描述
问题
我正在使用完成服务并生成子线程来执行一些ETL。 当我在IDE中调试然后停止所有进程时,我注意到我仍然有一堆僵尸线程杀死了我的CPU。这是因为我没有正确终止子线程。
最小示例
Future<Boolean> future = completionService.submit(conversionProcessor);
boolean isCompleted = false;
while (!isCompleted && !closed.get()) {
try {
isCompleted = future.get(CONSUMER_HEARTBEAT_INTERVAL,TimeUnit.SECONDS); // Wait until heartbeat interval exceeds
if (isCompleted) {
// do some things here
future.cancel(true);
break;
}
} catch (TimeoutException e) {
// Used to keep consumer alive in the cluster
consumer.poll(Duration.ofSeconds(CONSUMER_HEARTBEAT_INTERVAL)); // does heart-beat
} catch (CancellationException e) {
future.cancel(true);
break;
} catch (InterruptedException e) {
future.cancel(true);
break;
} catch (WakeupException we) {
future.cancel(true);
break;
} catch (Exception e) {
future.cancel(true);
break;
}
想法
基本上,我将Callable<Boolean>
提交给完成服务。
ExecutorCompletionService<Boolean> completionService = new ExecutorCompletionService<>(
Executors.newSingleThreadExecutor());
如果我停止调试器,则该线程可能仍在运行。我 just 添加了这个future.cancel(true)
,似乎已经停止从子线程连续上传文件,但是我仍然看到这些Java进程在我的活动监视器上运行。
我想知道我应该如何考虑?我想要可调用对象,因为它告诉我何时基础ETL是否已完成(true / false)
编辑: future.cancel实际上似乎在帮助很多。.这是我想使用的吗?
解决方法
完成CompletionService
处理后,您需要关闭基础执行程序,因此需要执行以下操作
ExecutorService es = Executors.newSingleThreadExecutor();
ExecutorCompletionService<Boolean> completionService = new ExecutorCompletionService<>(es);
还有结束通话
es.shutdown();
es.awaitTermination(1,TimeUnit.SECONDS);