1

我的消费者没有按照我期望的方式工作。下面是在我的真实程序中发生的事情。

  • 预期的：
    1. 打印In finally!
    2. 打印About to print stacktrace
    3. 打印NullPointerException堆栈跟踪。
  • 实际的：
    1. 打印In finally!
    2. 挂，在sun.misc.Unsafe

程序：

import java.lang.Thread.UncaughtExceptionHandler;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;

public class ThreadTest implements Runnable {
    public static void main(String... args) {
        ExecutorService service = Executors.newSingleThreadExecutor(new ThreadFactory() {
                    @Override
                    public Thread newThread(Runnable r) {
                        Thread newThread = new Thread(r);
                        newThread.setUncaughtExceptionHandler(new MyExceptionHandler());
                        return newThread;
                    }
                });
        service.submit(new ThreadTest());
    }

    private static class MyExceptionHandler implements UncaughtExceptionHandler {
        @Override
        public void uncaughtException(Thread t, Throwable e) {
            System.out.println("About to print stacktrace");
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        Object foo = null;
        try {
            while(!Thread.interrupted()) {
                Thread.sleep(1000);
                System.out.println(foo.toString());
                System.out.println("After npe!");
            }
        } catch(InterruptedException e) {

        } finally {
            System.out.println("In finally!");
        }
    }
}
4

1 回答 1

2

在 Executor 中运行的 Runnables 不会真正抛出异常，这会影响线程的未捕获异常处理程序。相反，Runnable 用捕获 Throwable 的代码包装。这是为了让 Future 可以返回从任务中抛出的异常。

正如@Gray 在下面的评论中指出的那样，您的程序正在“挂起”，因为线程池线程正在阻止程序退出。您的可运行对象已完成，线程池线程正在等待新任务。如果您关闭线程池，您的程序将正常完成（或使线程池线程守护进程）。

于 2013-09-27T20:45:29.633 回答