Поток Java начинает следующую карту до завершения предыдущей ⇐ JAVA

[Anonymous]

У меня 2 исполнителя:

Код: Выделить всё

ExecutorService executorDownload = Executors.newFixedThreadPool(n);
ExecutorService executorCalculate = Executors.newFixedThreadPool(m);

Сначала мне нужно поместить задачи в исполнитель Download, затем после их завершения поместить их в executorCalculate и получить результат. Я написал следующий поток:

Код: Выделить всё

long count = IntStream.range(0, TASK_NUMBER)
.boxed()
.parallel()
.map(i -> executorDownload.submit(new Download(i)))
.map(future -> calculateResultFuture(executorCalculate, future))
.filter(Objects::nonNull)
.filter(Main::isFutureCalculated)
.count();

public static Future calculateResultFuture(ExecutorService executorCalculate, Future future) {
try {
return executorCalculate.submit(new Calculate(future.get()));
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
return null;
}

public static boolean isFutureCalculated(Future future) {
try {
return future.get().found;
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
return false;
}

Можно ли как-то запустить

Код: Выделить всё

.map(future -> calculateResultFuture(executorCalculate, future))

до

Код: Выделить всё

.map(i -> executorDownload.submit(new Download(i)))

завершилось. Мне нужно запустить вторую карту сразу после запуска первой.

Подробнее здесь: https://stackoverflow.com/questions/661 ... evious-one