Текущий статус монитора

Question

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

Я думаю, я знаю несколько способов для достижения этой цели, но я хотел бы знать ваше мнение по поводу некоторых вещей:

• Am Я просто стремлюсь ни за что? Я имею в виду, если я в идеале попытаюсь поймать весь код, который может пойти не так, будет ли нить когда-либо предавать меня по какой-либо очевидной причине?
• Что лучше всего делать, что я изложил? Периодически проверяйте состояние потока с помощью другого потока и ScheduledExecutor? Реализовать какую-то модель наблюдаемого наблюдателя?

Answer 1

Вы можете создать ExecutorService, который слушает события через Executors.newSingleThreadExecutor(). В этом случае вам не нужно смотреть на поток, если это здорово, ExecutorService позаботится об этом. SingleThreadExecutor отвечает за то, что одновременно запускается только одна задача (Runnable или Callable).

Answer 2

Если вы проверяете использование стандартных Java-методов для правильного просмотра состояния потока, у вас не должно быть никаких ошибок. В случае, если выбрано исключенное исключение или поток выходит из-за какой-то странной причины, блок try-finally должен быть достаточным для запуска нового потока (также убедитесь, что он не является демоном). Вы можете использовать цикл while с периодической паузой, предпочтительно используя механизм планирования потока, такой как timed wait(...) или timed LockSupport#park(...). Вы также можете спать в потоке.

Answer 3

Нить никогда не должны перестать работать, и если это произойдет, ...

ОК, так что писать так, чтобы она никогда не перестанет работать.

public void run() { 
    while (true) { 
     try { 
      Message message = receiveNextMessage(); 
      handleMessage(message); 
     } catch (Exception ex) { 
      LOGGER.error(ex); 
      if (somethingTrulyHorribleHasHappened(ex)) { 
       Runtime.getRuntime().exit(1); 
      } else { 
       maybeResetSomethingThatNeedsToBeReset(); 
      } 
     } 
    } 
} 

Answer 4

Это несколько бессмысленное и бесполезное упражнение. Жизненный поток приложения должен быть отлажен и сделан, чтобы не останавливаться. Основной поток вашего приложения длится всю жизнь процесса, а любые другие потоки должны быть спроектированы, протестированы и отлажены по одному и тому же стандарту.

Что произойдет, если остановленный поток испортил данные в других потоках, когда он разбился? Если вы как-то перезапустили его, повреждение данных может ухудшить ситуацию.