如何处理ExecutorService ThreadFactory返回null而不是thead的情况

Question

我以前问过这个问题，但无法再次打开它，因为我的更新没有启动重新打开的过程。所以重新提交

我的问题是如何让ExecutorService立即意识到线程无效（null），而不必等待将来的get。

我有一个用例，在ThreadFactory中创建线程时，如果无法正确设置线程（例如，它无法连接到服务器），我希望返回null。

当ExecutorService对可调用对象运行submit时，ThreadFactory返回null，如下所示，代码将运行，但将在将来等待。get（5，TimeUnit.SECONDS）；然后抛出一个TimeoutException。问题是ThreadFactory.newThread（）不允许我在这里抛出异常。

public class TestThreadFactory implements ThreadFactory {
    @Override
    public Thread newThread(Runnable r) {
        // try to create a conneciton that fails 
        // I cannot throw an exception here, so if there is a problem I have to  return null
        return null;
    }
}

public class ExecutorServicePool {

    public static ExecutorService getService() {
        return Executors.newFixedThreadPool(10, new TestThreadFactory());
    }
}

public static void main(String[] args) {
    ExecutorService executorService = ExecutorServicePool.getService();

    Callable callable = new Callable<String>() {
        @Override
        public String call() throws Exception {
            return "callable";
        }
    };

    Future<String> future = executorService.submit(callable);
    try {
        future.get(5, TimeUnit.SECONDS);
    } catch (InterruptedException e) {
        e.printStackTrace();
    } catch (ExecutionException e) {
        e.printStackTrace();
    } catch (TimeoutException e) {
        e.printStackTrace();
    }
    executorService.shutdown();
}

Answer 1

您可以通过扩展ThreadPoolExecutor和

根据需要重写调用threadfactory以获取新线程的方法。

Answer 2

你可以抛出一个运行时异常，这感觉是一件明智的事情。

对于通常不可恢复的情况，RuntimeExc0019非常有用。例如，无法连接到数据库就是其中一种情况的主要例子。基本上在这种情况下，你想说：

“出现问题，目前我无法处理您的请求。请稍后再试”

RuntimeExceptions可以在方法实现中抛出，即使接口没有声明它们。因此，您可以更新ThreadFactory实现以抛出RuntimeException而不是返回null。您甚至可以创建一个特定的RuntimeException子类，以确保清楚应用程序中的错误，例如FailedToInitialiseThreadException