ThreadPoolExecutor - 提交和执行方法之间的区别？ [复制]

Question

我遇到了关于ThreadPoolExecutor 的问题。

写了一些代码后发现submit()方法会吃掉程序抛出的RuntimeException，但是execute()方法会重新抛出RuntimeException`。我想知道这是什么原因。

最近看了ThreadPoolExecutor的源码，知道了线程池的原理。 现在我明白了execute() 方法是如何执行的，但是我不明白submit() 方法是如何执行的。我只知道submit()方法会将Runnable或Callable包裹在FutureTask中并调用execute()方法：

public Future submit(Runnable runnable)
{
    if(runnable == null)
    {
        throw new NullPointerException();
    } else
    {
        RunnableFuture runnablefuture = newTaskFor(runnable, null);
        execute(runnablefuture);
        return runnablefuture;
    }
}

那么，我的问题是：ThreadPoolExecutor 是如何执行FutureTask 的，为什么RuntimeException 被吃掉了？

Answer 1

如果您查看newTaskFor 方法，您会发现RunnableFuture 实际上是java.util.concurrent.FutureTask 的实例。您应该会在此 FutureTask 类中看到 run 方法。

public void run() {
    sync.innerRun();
}

这里是 innerRun 方法：

    void innerRun() {
        if (!compareAndSetState(READY, RUNNING))
            return;

        runner = Thread.currentThread();
        if (getState() == RUNNING) { // recheck after setting thread
            V result;
            try {
                result = callable.call();
            } catch (Throwable ex) {
                setException(ex);
                return;
            }
            set(result);
        } else {
            releaseShared(0); // cancel
        }
    }

异常被捕获并设置为任务。当你调用 FutureTask 的 get 方法时，它会被包裹到 ExecutionException 中

 public V get() throws InterruptedException, ExecutionException {
    return sync.innerGet();
}