Порядок исполнения вызываемых абонентов не соответствует

Question

У меня есть этот код, где я выполняю наборы вызываемых элементов, мне нужен один набор, чтобы завершить всю свою работу перед запуском следующего набора. Этот код работает нормально, но иногда следующий набор запускается раньше времени. Что здесь не так?

private void executeSubGraph(QuestExecutionContext ctx, Set<Activity> subGraph, int progressAfterRan) {
    ExecutorService pool = Executors.newFixedThreadPool(16);
    subGraph.forEach(a -> {
        ActivityRunner<? extends Activity> runner = activityRunnerFactory.getRunner(ctx, a);
        if (runner != null) {
            Callable<List<PortValuePart>> runnerCallable = () -> {
                try {
                    LOG.info("Running {} in {}", a, a.getClass() );
                    List<PortValuePart> result = runner.call();
                    LOG.info("Result of {} in {} is {}", a, a.getClass(), result);
                    if (result != null) {
                        result.forEach(r -> resultProcessor.processResult(new PortValuePartEnvelope(r)));
                    }
                    return result;
                } catch (Exception e) {
                    LOG.warn("Exception for {} in {}", a, runner.getClass(), e);
                    resultProcessor.processResult(Progress.failed(ctx.getId(), e));
                    throw new RuntimeException(e);
                }
            };
            Future<List<PortValuePart>> p = pool.submit(runnerCallable);
        } else {
            LOG.warn("No runner found for activity {}", a);
            resultProcessor.processResult(Progress.failed(ctx.getId(), new RuntimeException("No runner found for activity " + a)));
            throw new RuntimeException("No runner found for activity " + a);
        }
    });

    pool.shutdown();

    try {
        pool.awaitTermination(WAIT_TIME_MILLIS, TimeUnit.MILLISECONDS);
        resultProcessor.processResult(Progress.running(ctx.getId(), progressAfterRan));
    } catch (InterruptedException e) {
        throw new PlatformException("Execution interrupted.");
    }
}

Answer 1

Обратите внимание, что ExecutorService.awaitTermination не выдает исключение, если оно истекло; это просто возвращает false, Если вы хотите убедиться, что следующие вызовы не будут выполняться одновременно с этими, вам, вероятно, следует использовать возвращаемое значение и, возможно, выдать исключение (и убить задачи), если оно занимает слишком много времени.