超时后中断任务的ScheduledExecutorService和ThreadPoolTaskExecutor

Question

我使用ExecutorService在超时后中断任务，为此我使用ScheduledExecutorService。首先，我提交的线程和它一次开始立即，并保留未来的创建。之后，我使用ScheduledExecutorService作为一个新任务，它将在一段时间后取消保留的future。

//Start Spring executor to submit tasks
ThreadPoolTaskExecutor taskExecutor = (ThreadPoolTaskExecutor) ApplicationContextProvider.getApplicationContext().getBean("taskExecutor"); 

CompletionService completionService = new ExecutorCompletionService(taskExecutor);
//End Spring executor to submit tasks

// Start ScheduledExecutorService  to submit returned future object to timeout

ScheduledExecutorService executor = Executors.newScheduledThreadPool(Integer.parseInt(config.getProperty("DBPOLLER_COREPOOLSIZE")));

final Future<String> future = completionService.submit(batchJob); // Submit actual task and get future

// submit future

executor.schedule(new Runnable() {
      public void run() {
                         future.cancel(true);
      }
   }, dbPollerTimeOut, TimeUnit.MINUTES);

int count = taskExecutor.getActiveCount();

 if (count == 0) {

                taskExecutor.shutdown();
                executor.shutdown();
                finalExitStatus = 0;                    
                break;

            } 

我已经实现了以下URL：ExecutorService中的解决方案，该解决方案在超时后中断任务，在超时之前它工作得很好，但是一旦发生超时，它将取消所有Enter code here我线程池中的任务，这是不可接受的。我只需要取消长时间运行的任务，并达到超时。

你知道怎么做到这一点吗？

Answer 1

不清楚您的CompletionService是什么，并且您正在提交您的BatchJob，因此很难确定问题的确切根源。但是提交少量任务并在一段时间后取消这些任务的理想情况是同时使用ScheduledExecutorService。

因此，可以尝试在scheduledexecutorservice即executor的实例上提交batchjob。

final Future<String> future = executor.submit(batchJob); // Submit actual task and get future       

编辑更新：您应该在代码中做的重要更改
我看到您从未停止您的ScheduledExecutorService，这是错误的，因为它占用的资源在停止之前永远不会释放。因此，更新后的代码应该如下所示：

ScheduledExecutorService executor = Executors.newScheduledThreadPool(Integer.parseInt(config.getProperty("DBPOLLER_COREPOOLSIZE")));
final Future<String> future = executor.submit(batchJob); // Submit actual task and get future
executor.schedule(new Runnable() {
      public void run() {
        future.cancel(true);
        executor.shutdownNow();
      }
   }, dbPollerTimeOut, TimeUnit.MINUTES);