如何在 junit 中使用未捕获的异常处理程序进行多线程测试？

Question

我有以下代码，我希望能够成功运行完成，但代码在“fail(”不应达到此值”);”行处失败。有人可以解释一下为什么不调用默认的未捕获异常处理程序：

public class UncaughtExceptionTest extends TestCase
    implements UncaughtExceptionHandler {

    private final List<Throwable> uncaughtExceptions =
        new CopyOnWriteArrayList<Throwable>();

    class UncaughtExceptionTestInnerClass implements Runnable {
        private final ScheduledThreadPoolExecutor executor =
            new ScheduledThreadPoolExecutor(1);
        private final CountDownLatch latch;

        UncaughtExceptionTestInnerClass(CountDownLatch latch) {
            this.latch = latch;
            executor.schedule(this, 50, TimeUnit.MILLISECONDS);
        }

        @Override
        public void run() {
            System.out.println("This is printed");
            fail("this should fail");
            latch.countDown();
        }
    }

    @Test
    public void testUncaughtExceptions() {
        Thread.setDefaultUncaughtExceptionHandler(this);
        CountDownLatch latch = new CountDownLatch(1);
        UncaughtExceptionTestInnerClass testTheInnerClass =
                new UncaughtExceptionTestInnerClass(latch);
        try {
            if (!latch.await(1, TimeUnit.SECONDS)) {
                if (uncaughtExceptions.size() > 0) {
                    Throwable exception = uncaughtExceptions.get(0);
                    System.out.println("First uncaught exception: " + 
                                    exception.getMessage());
                }
                else {
                    fail("this should not be reached");
                }
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void uncaughtException(Thread t, Throwable e) {
        uncaughtExceptions.add(e);
    }
}

Answer 1

这与您使用执行器来运行任务这一事实有关。仅当线程由于未捕获的异常而即将终止时，才会调用未捕获的异常处理程序。如果您将实现更改为使用普通线程，以便线程将因异常而终止，您将看到预期的行为。

根据您提交任务的方式，执行器线程可能会捕获所有 Throwable 并处理它们。因此，线程不会因这些异常而终止，因此未捕获的异常处理程序不会参与其中。例如，ThreadPoolExecutor.execute(Runnable)将触发未捕获的异常处理程序。但是，ThreadPoolExecutor.submit(Callable) 则不然。另外， ScheduledThreadPoolExecutor.schedule() 也没有（这与他们使用 FutureTask 进行实现有关）。

使用执行器服务访问意外异常的更好方法是通过 Future。

Answer 2

ScheduledThreadPoolExecutor.schedule() 采用 Runnable/Callable 参数，而不是 Thread。前者没有运行时异常处理程序。在 run 或 call 方法中为 RuntimeException 提供一个 try/catch 块。