Запросы о Java Future and RejectionHandler

Question

У меня возникли некоторые вопросы относительно использования Future. Пожалуйста, перейдите к примеру ниже, прежде чем обращаться к моим запросам.

http://javarevisited.blogspot.in/2015/01/how-to-use-future-and-futuretask-in-Java.html

1. Основная цель использования пулов потоков & Executors это выполнить задачу асинхронно, не блокируя основной поток. Но как только вы используете Future, он блокирует вызывающий поток. Нужно ли создавать отдельный пул потоков/потоков для анализа результатов задач Callable? ИЛИ есть ли другое хорошее решение?
2. С Future вызов блокирует вызывающего абонента, стоит ли использовать эту функцию? Если я хочу проанализировать результат задачи, я могу иметь синхронный вызов и проверять результат вызова без Future.
3. Каков наилучший способ справиться с отклоненными задачами с использованием RejectionHandler? Если задача отвергается, следует ли перевести задачу на другой поток или ThreadPool или отправить эту же задачу в текущую ThreadPoolExecutor?

Пожалуйста, исправьте меня, если мой мыслительный процесс не соответствует этой функции.

Answer 1

Ваш вопрос о выполнении действия при выполнении асинхронного действия. Future s, с другой стороны, хороши, если у вас есть несвязанная деятельность, которую вы можете выполнять во время выполнения асинхронного действия. Затем вы можете регулярно проверять действие, представленное Future, на isDone() и делать что-то еще, если нет, или вызвать блокировку get(), если у вас больше нет несвязанной работы для вашего текущего потока.

Если вы хотите запланировать выполнение по завершении без блокировки текущего потока, вы можете вместо этого использовать CompletableFuture, который предлагает такую ​​функциональность.

Answer 2

CompletableFuture подходит для запросов 1 и 2, как было предложено @Хольгера

Я хочу обновить около RejectedExecutionHandler механизма относительно запроса 3.

Java обеспечивает четыре типа политики Неприятие Handler согласно javadocs ,

1. В умолчанию ThreadPoolExecutor.AbortPolicy, обработчик бросает выполнения RejectedExecutionException на отказ.

2. В ThreadPoolExecutor.CallerRunsPolicy поток, запускающий выполнение, выполняет задание. Это обеспечивает простой механизм управления с обратной связью, который замедляет скорость подачи новых задач.

3. В ThreadPoolExecutor.DiscardPolicy задача, которая не может быть выполнена, просто отбрасывается.

4. В ThreadPoolExecutor.DiscardOldestPolicy, если исполнитель не закрыт, задача во главе рабочей очереди отбрасывается, а затем выполняется повторное выполнение (что может снова потерпеть неудачу, в результате чего это будет повторяться.)

CallerRunsPolicy: Если у вас есть задачи в очереди задач, с помощью этой политики приведет к ухудшению производительности. Вы должны быть осторожны, поскольку задачи отклонения будут выполняться самим потоком. Если выполнение отклоненной задачи имеет решающее значение для вашего приложения и у вас ограниченная очередь задач, вы можете использовать эту политику.

DiscardPolicy: Если отбрасывание некритического события вас не беспокоит, вы можете использовать эту политику.

DiscardOldestPolicy: Выбросьте старую работу и попытаться возобновить последний

Если ни один из них не подходит для ваших потребностей, вы можете реализовать свой собственный RejectionHandler.