Java daemon - обработка запросов на завершение работы

Question

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

У меня есть настройка закрытия выключения, и когда она называется, она устанавливает переменную, сообщающую основному циклу демона, чтобы остановить работу. Проблема в том, что этот демон порождает несколько потоков, и они могут занять много времени. Например, один из этих потоков может преобразовывать документ. Большинство из них будут быстрыми (я думаю, до 10 секунд), но будут темы, которые могут длиться до 10 + минут.

Что я сейчас делаю, когда отправлен крюк отключения, сделайте цикл в течение 5 секунд на ThreadGroup.activeCount() с помощью спящего режима (или около того) (все эти потоки находятся в ThreadGroup), и до этого цикла я отправлю уведомление всем потокам, сообщающим им, что вызван запрос на завершение работы. Тогда они должны будут немедленно, независимо от того, что они делают для очистки и выключения.

У кого-нибудь есть предложения? Меня интересует то, что делает демон, например MySQL, когда ему говорят останавливаться, он останавливается мгновенно. Что происходит, если работает 10 запросов, которые очень медленны? Подождите или просто закончит их. Я имею в виду, что серверы очень быстрые, поэтому на самом деле нет никакой операции, которую я не мог бы сделать менее чем за секунду. Вы можете сделать LOT в 1000ms сейчас дней.

Благодаря

Answer 1

java.util.concurrent package предоставляет ряд утилит, таких как ThreadPoolExecutor (наряду с различными специализированными типами других Executor реализаций от Executors класса) и ThreadPoolExecutor.awaitTermination(), которые вы могли бы хотеть смотреть в - как они обеспечивают точно такую ​​же функциональность, которую вы хотите реализовать. Таким образом, вы можете сосредоточиться на реализации фактических функций вашего приложения/задач, а не на том, чтобы беспокоиться о вещах, таких как планирование потоков и задач.

Answer 2

Являются ли ваши задания на резьбу доступными для прерывания через Thread#interrupt()? Они в основном призывают функции, которые сами рекламируют бросок InterruptedException? Если это так, то вышеупомянутый java.util.concurrent.ExecutorService#shutdownNow() - это путь. Он прервет любые запущенные потоки и вернет список заданий, которые никогда не запускались.

Точно так же, если вы повесите на к Future с производства ExecutorService#submit(), вы можете использовать Future#cancel(boolean) и передать true просить, чтобы беговая работа была прервана.

Если вы не звоните на код из вашего контроля, который проглатывает сигнал прерывания (скажем, при ловле InterruptedException без вызова Thread.currentThread().interrupt()), используя встроенный в кооперативном прерывании объекта является лучшим выбором, чем введение собственных флагов приблизить то, что уже здесь.