ThreadPools'ta özel durum yönetimi

Question

İstisnalar yemek gibi görünen bir ScheduledThreadPoolExecutor var. Gönderilen bir Runnable bir istisna atarsa, icracı servisimin beni bilgilendirmesini istiyorum.

Örneğin, ben bir yan soru olarak IndexArrayOutOfBoundsException en StackTrace

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

yazdırmak en azından aşağıdaki kodu istiyorum. ScheduledThreadPoolExecutor için genel bir try catch bloğu yazmanın bir yolu var mı? ORİJİNAL SORU

////////// SON //////////////

olarak aşağıdaki Dekoratör iyi çalışıyor önerdi.

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

Bu sorun hakkında bir süre önce küçük bir post yazdım.

ancak bunun yerine bir UncaughtExceptionHandler atama Mark Peters solution değiştirilmiş bir sürümünü kullanın (her yürütür hangi kendinize ait bir çalıştırılabilir içine çalıştırılabilir ibraz sarmak

1. Colin Herbert tarafından sağlanan solution veya
kullanın: İki seçeneğiniz vardır Bir try-catch-blok içinde gerçek runnable run çağırır.

DÜZENLEME
olarak, Runnable yerine ThreadFactory geçirilen birinin ScheduledExecutorService geçirilen sarmak için önemli, Mark dikkat çekti.

Answer 2

Uyarı: Bu yöntem planlanan parçacığı havuzu emirleri yerine getirenlerin uygulanamaz. Bu yanıt, diğer iş parçacığı havuzu yürütücülerle olan ilişkisi nedeniyle geri alındı. Bakınız Willi's answer. ThreadFactory Parçacıkları bir UncaughtExceptionHandler vermek

geçersiz kılma:

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

sizin ScheduledThreadPoolExecutor bir istisnası atılır eğer görevlerden herhangi birini çağırabilir sınıf statik bir olay eklemeyi düşünün. Bu şekilde, iş parçanızda gerçekleşen istisnaları yakalamak ve ele almak için bu etkinliği kullanabilirsiniz.

Answer 4

Futureget() yöntemini, scheduleAtFixedRate() numaralı telefonu arayarak kullanabilirsiniz. İş parçacığı yürütme sırasında bir yürütme oluştuğunda ExecutionException atar.

Answer 5

Ayrıca, Spring Framework numaralı telefondan ThreadPoolTaskScheduler, hata işleyiciyi ayarlamak için bir yöntem ortaya koyar ve sizin için tüm kaydırma işlemini gerçekleştirebilirsiniz. Varsayılan davranış, göreve göre değişir:

Verilen ErrorHandler boş değilse, kullanılacaktır. Aksi takdirde, yinelenen görevler varsayılan olarak bastırılırken, tek vuruşlu görevler varsayılan olarak yayılan hatalara sahip olur, çünkü bu hatalar döndürülen Future aracılığıyla beklenebilir. Her iki durumda da, hatalar günlüğe kaydedilir.

sadece sarma kısmını değil TaskScheduler kullanmak istiyorsanız TaskScheduler kullandığı bilgileri içermektedir

TaskUtils.decorateTaskWithErrorHandler(task, errorHandler, isRepeatingTask) 

kullanabilirsiniz.

Answer 6

ScheduledThreadPoolExecutor alt sınıfını ve gönderdiğiniz tüm Runnable'lar için istisnaları ve hataları işlemek için afterExecute yöntemini geçersiz kılabilirsiniz.