ExecutorService-在特定的时间限制内执行每个任务

Question

我正在创建一个ExecutorService执行某些任务的程序，在正常条件下，这些任务可能需要一分钟才能完成，但是在任何情况下，从任务开始时不得超过两分钟。

我的代码如下：

ExecutorService executorService = Executors.newFixedThreadPool(10);
ArrayList<Future<?>> futuresList = new ArrayList<Future<?>>();



for (String singleTask: taskList) { 
                futuresList.add(executorService.submit( new Runnable(){      
                       @Override
                       public void run(){
                        try {
                            performTask(p1, singleTask, p3);
                        } catch (IOException | InterruptedException | ExecutionException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                }
              }
         }));       

    }



for(Future<?> future : futures) {
    future.get(120, TimeUnit.SECONDS); 
}

这将阻塞直到指定的超时，然后继续。我的问题如下：

1）如果task1阻塞了两分钟，task2并且阻塞了两分钟-那么task2将“阻塞”总共4分钟（因为future.get(120, TimeUnit.SECONDS); 直到task1完成阻塞才在task2上调用它）-即使两个任务都在同一时间提交并开始执行时间

2）如果我提交的任务多于10个，则future.get(120, TimeUnit.SECONDS); 在第11个任务上调用之前的任务尚未完成的情况下，任务11+可能永远不会阻塞所需的时间

我的目标是使每个任务最多执行两分钟，而不管列表中的任务数量如何，以及之前或之后有多少个任务。

谢谢

Answer 1

您可以使用 System.currentTimeMillis(); 来花时间；然后添加最大时间，例如 120_000 毫秒。当你等待时，你减去当前时间。也就是说，您只需等到达到最大时间即可。