Обработка исключений в ThreadPools

Question

У меня есть ScheduledThreadPoolExecutor, который, кажется, есть Исключения. Я хочу, чтобы моя служба-исполнитель уведомила меня, если представленный Runnable генерирует исключение.

Например, я хотел бы код ниже, чтобы по крайней мере, печать на IndexArrayOutOfBoundsException в StackTrace

threadPool.scheduleAtFixedRate(
    new Runnable() { 
    public void run() { 
     int[] array = new array[0]; 
     array[42] = 5; 
    } 
    }, 
    1000, 
    1500L, 
    TimeUnit.MILLISECONDS); 

В качестве побочного вопроса. Есть ли способ написать общий блок catch try для ScheduledThreadPoolExecutor?

////////// КОНЕЦ ОРИГИНАЛЬНЫЙ ВОПРОС //////////////

Как было предложено следующее декоратор работает хорошо.

public class CatcherTask implements Runnable{ 

    Runnable runMe; 

    public CatcherTask(Runnable runMe) { 
     this.runMe = runMe; 
    } 

    public void run() { 
     try { 
      runMe.run(); 
     } catch (Exception ex){ 
      ex.printStackTrace(); 
     } 
    } 
} 

Answer 1

Я написал небольшую post об этой проблеме некоторое время назад. У вас есть два варианта:

1. Используйте solution предоставленную Colin Херберт или
2. используют модифицированную версию Mark Peters solution но вместо назначения UncaughtExceptionHandler вы обернуть каждый представленный работоспособной в работоспособной ваших собственных, который выполняет (вызывает run) реальный runnable внутри блока try-catch.

EDIT
Как отметил Марк, очень важно, чтобы обернуть Runnable перешел к ScheduledExecutorService вместо одного переданного ThreadFactory.

Answer 2

Предупреждение: Этот метод не применим к запланированными пула потоков исполнителей. Этот ответ был восстановлен за его соответствие другим исполнителям пула потоков. См. Willi's answer.

Override ThreadFactory дать Threads в UncaughtExceptionHandler:

ThreadPoolExecutor exec = new ThreadPoolExecutor...; 

exec.setThreadFactory(new ExceptionCatchingThreadFactory(exec.getThreadFactory())); 
//go on to submit tasks... 


private static class ExceptionCatchingThreadFactory implements ThreadFactory { 
    private final ThreadFactory delegate; 

    private ExceptionCatchingThreadFactory(ThreadFactory delegate) { 
     this.delegate = delegate; 
    } 

    public Thread newThread(final Runnable r) { 
     Thread t = delegate.newThread(r); 
     t.setUncaughtExceptionHandler(new UncaughtExceptionHandler() { 
      @Override 
      public void uncaughtException(Thread t, Throwable e) { 
       e.printStackTrace(); //replace with your handling logic. 
      } 
     }); 
     return t; 
    } 
} 

Answer 3

Рассмотрит добавление статического события в вашем ScheduledThreadPoolExecutor класса, что любой из ваших задач можно вызвать, если исключение. Таким образом, вы можете использовать это событие для захвата и обработки исключений, возникающих в ваших потоках.

Answer 4

Вы можете использовать метод get() от Future, который вы получаете по телефону scheduleAtFixedRate(). Он выкинет ExecutionException, если во время выполнения потока произошла утечка.

Answer 5

Вы также можете использовать ThreadPoolTaskScheduler от Spring Framework, который предоставляет метод установки обработчика ошибок и выполняет всю вашу упаковку. Поведение по умолчанию зависит от типа задачи:

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

Если вы хотите использовать только оберточную часть и не TaskScheduler вы можете использовать

TaskUtils.decorateTaskWithErrorHandler(task, errorHandler, isRepeatingTask) 

которой TaskScheduler использует внутренне.

Answer 6

Вы можете подклассифицировать ScheduledThreadPoolExecutor и переопределить метод afterExecute для обработки исключений и ошибок для любого вида Runnable, который вы отправляете.