java - 从完成服务中杀死线程?
问题描述
问题
我正在使用完成服务并产生子线程来执行一些 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());
如果我停止调试器,该线程可能仍在运行。我刚刚添加了future.cancel(true)
这块,它似乎已经停止从我的子线程连续上传文件,但我仍然看到这些 java 进程在我的活动监视器上运行。
我想知道我应该如何考虑这个问题?我想要可调用的,因为它告诉我底层 ETL何时完成(真/假)
编辑:future.cancel 实际上似乎有很大帮助..这是我想要使用的吗?
解决方案
完成后,您CompletionService
需要关闭底层执行程序,因此您需要执行以下操作
ExecutorService es = Executors.newSingleThreadExecutor();
ExecutorCompletionService<Boolean> completionService = new ExecutorCompletionService<>(es);
和结束电话
es.shutdown();
es.awaitTermination(1, TimeUnit.SECONDS);
推荐阅读
- pycharm - 如何让 Pycharm 识别类类型?
- mongodb - Mongoose 使用 getter 函数填充虚拟字段不起作用
- html - Bootstrap粘性导航在粘性时无法溢出容器外?
- sql - SQL Error (Missing Operator) 查询操作错误
- python - 运行 python manage py migrate 时出错
- javascript - rxjs:随着用户移动滑块逐渐获取值,在先前完成后发送新请求
- android - 如何从java将触摸坐标传递给片段着色器?
- docker - 文件为空,共享卷
- laravel - 在 laravel 中创建一个登录名,其中凭据不在同一个数据库中
- android - 如何构建符合 Google Play 64 位要求的应用程序?