java cachedThreadPool终止提交的线程

Question

我需要做一些多线程工作，并使用ExecutorService。newCachedThreadPool（）并提交从队列中检索到的一些作业。

public class ContentParser {
    public static ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
    // ...

    public static void queueExecutor(Content content)  {
        String url = "";
        while ((url = queue.poll()) != null){
            LOG.info("Picked url " + url);
            cachedThreadPool.submit(new ParserCallable(content, url));
        }
    }

    // ...

private static class ParserCallable implements Runnable {
    private Content content;
    private String url;
    private ParserCallable(Content content, String url) {
        this.url = url;
        this.content = content;
    }

    @Override
    public void run(){
        new FontParser().fontSearcher(content, url);
    }
}

所以每个线程都创建一个FontParser的新实例，我在其中做一些工作。

我从另一个类调用我的ContentParser.queue执行器，所以在提交所有作业后，我这样做：

ContentParser.cachedThreadPool.shutdown();
ContentParser.cachedThreadPool.awaitTermination(5l, TimeUnit.MINUTES);

但它只会杀死我的线程，即使工作没有完成，也没有等待。

也许是因为我在每个线程中创建了一个新的实例new FontParser（）. fontSearcher（内容，url）；？

Answer 1

我从另一个类调用我的ContentParser.queue执行者，所以在提交所有作业后，我这样做：

听起来好像有人在调用cachedThreadPool。shutdown（）但作业仍在提交到池中。这不应该发生<代码>关机（）只能在循环完成后调用。

我建议在您的queueExecitor（...）方法中执行以下操作：

while ((url = queue.poll()) != null){
    LOG.info("Picked url " + url);
    cachedThreadPool.submit(new ParserCallable(content, url));
}
// shutdown _after_ all jobs have been submitted
cachedThreadPool.shutdown();

此外，一般来说，将字段公开是一种不好的做法，尤其是在本例中，您的缓存线程池（cachedThreadPool）字段。您无法控制外部类如何（或在这种情况下何时）调用池上的关键方法。我会将其设置为私有，然后在您的ContentParser类上有一个wait方法：

private static ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
...
public static void awaitPoolTermination(/* maybe timeout args here */) {
    cachedThreadPool.awaitTermination(5l, TimeUnit.MINUTES);
}

这样可以更好地控制线程池，并且不允许在不适当的地方关闭。因此，ContentParser方法的调用者将首先调用contentParser.queueExecitor（...），然后调用contentParser.awaitPoolTermer（...）。