Java – выполнять несколько Runnables параллельно и запускать тайм-аут некоторых длительных задач? ⇐ JAVA

[Anonymous]

У меня есть список выполняемых задач (например, он содержит 100 задач, и каждая задача случайным образом занимает 1–10 секунд). Задачи должны выполняться параллельно и из пула потоков, предоставленного ExecutorService (например, в моей системе 4 процессора, тогда она должна выполнять 4 задачи одновременно).Вопрос: я хотел знать, какие задачи из списка из 100 задач выполнялись дольше 5 секунд и их следует завершить (с журналами идентификаторов задач) через 5 секунд. секунды, чтобы иметь места для другие задачи.
Я просмотрел Future с помощью executorService.submit(Runnable Task), но метод Future.get() заблокирует основная тема, и это не то, что я хотел. Будем рады любым предложениям.
public class TestExecutorService {

private static final ExecutorService executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() * 10);

public static void main(String[] args) throws InterruptedException {
List tasks = new ArrayList();

for (int i = 0; i < 100; i++) {
int finalI = i;
int min = 1;
int max = 8;

Runnable runnable = new Runnable() {
@Override
public void run() {
try {
int sleepTime = min + (int)(Math.random() * ((max - min) + 1));
System.out.println("## Thread: " + finalI + " will sleep: " + sleepTime + " seconds.");
Thread.sleep(sleepTime * 1000);
System.out.println("## Thread: " + finalI + " finished after: " + sleepTime + " seconds");
} catch (InterruptedException e) {
System.out.println("Thread is cancelled!");
}
}
};

tasks.add(Executors.callable(runnable));
}

// How to make a Runnable task timeout after 5 seconds when running other tasks in parallel
// instead of total time for 100 tasks in 5 seconds?
executorService.invokeAll(tasks, 5, TimeUnit.SECONDS);

executorService.shutdown();
}
}


Подробнее здесь: https://stackoverflow.com/questions/763 ... ome-of-lon