Как отменить конкретную задачу по таймауту при использовании ThreadPoolExecutor в Java?

Question

Я использую ThreadPoolExecutor в Java для параллелизации обработки элементов. Каждая обработка элемента - отдельная задача, поэтому я помещаю ее в очередь для обработки исполнителем. К сожалению, некоторые задачи могут занять слишком много времени, и я хочу иметь возможность отменить такие задачи и продолжить работу с остальными. Я не хочу ждать метода shutdown и его таймаута (общая обработка занимает несколько дней). Я хочу что-то вроде цикла по выполняемым в настоящее время задачам и проверке того, как долго он работает, и отмените его, если он превысил лимит.

Answer 1

ThreadPoolExecutor возвращает объекты Future для вас, когда вы отправляете задания на него.

Используйте метод get(long timeout, TimeUnit unit) на своем фьючерсе, и если вы получите TimeoutException, а затем отмените их.