ExecutorService invokeAll () дублирует вызываемый вызываемый

Question

У меня проблема при попытке вызвать список вызываемых из fixedThreadPool.В то время как все вызовы будут выполняться, некоторые из них, похоже, будут отправлены в разные потоки одновременно, поэтому они на самом деле вызываются более одного раза.Смотрите код ниже:

try {
    ExecutorService es = Executors.newFixedThreadPool(Environment.nThreads);
    es.invokeAll(Environment.jobPool);
    es.shutdown();
} catch (InterruptedException e) {
    e.printStackTrace();
}

Answer 1

Если вызываемый объект генерирует необработанное исключение, поведение не определено. Для прерванного исключения в останавливает ExecutorService, например. Кроме того, поскольку incokeAll принимает коллекцию, создайте HashSet из вашего ArrayList и передайте его, чтобы убедиться, что у вас ничего не продублировано

Set<?> set = new HashSet<?>(jobPool);

Я почти уверен, что ExecutorService не просто дважды вызывает один и тот же Callable.

Answer 2

Вы, вероятно, продублировали некоторые из ваших Callable задач в списке.Попробуйте использовать java.util.Set, правильно реализующий метод equal каждой реализации Callable.