从完成服务中杀死线程？

Question

问题

我正在使用完成服务并生成子线程来执行一些 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 进程运行在我的 activity 显示器上。

我想知道我应该如何考虑这个问题？我想要可调用的，因为它告诉我何时底层 ETL 是否已完成 (true/false)

编辑： future.cancel 实际上似乎很有帮助..这是我想要使用的吗？

Answer 1

完成 CompletionService 后，您需要关闭底层执行程序，因此您需要执行以下操作

ExecutorService es = Executors.newSingleThreadExecutor();
ExecutorCompletionService<Boolean> completionService = new ExecutorCompletionService<>(es);

结束通话

es.shutdown();
es.awaitTermination(1, TimeUnit.SECONDS);

从完成服务中杀死线程？

Killing threads from completion service?

java

multithreading

executorservice

completion-service

问题

最小示例

想法