Java线程完成后悬挂在完成后（）

Question

我有简单的测试代码：

public static void main(String[] args) {
    CompletionService<Integer> cs = new ExecutorCompletionService<>(Executors.newCachedThreadPool());
    cs.submit(new Callable<Integer>() {
        public Integer call(){
            try{
                Thread.sleep(3000); // Just sleep and print
                System.out.println("Sleeping thread: " + Thread.currentThread().getId());
            }catch(InterruptedException e){
                e.printStackTrace();
            }
            return 10;
        }
    });
    try{
        Future<Integer> fi = cs.take();
        System.out.println(fi.get());
    }catch(Exception e){
        e.printStackTrace();
    }
}

我运行它，睡3秒钟，然后打印，

Sleeping thread: 14
10

但随后挂在那里，程序没有结束。

发生了什么，如何完成？

Answer 1

如评论中提到的， tgdavies ，您的程序将在+/- 60秒后退出，因为那是默认超时的超时时间executorService在 opecutors.newcachedthreadpool（） 。

如果您不想等60秒，则在提交任务后应关闭执行人服务。

例如：

public static void main(String[] args) {
    ExecutorService executorService = Executors.newCachedThreadPool();
    try {
        CompletionService<Integer> cs = new ExecutorCompletionService<>(executorService);
        cs.submit(new Callable<Integer>() {
            public Integer call() {
                try {
                    Thread.sleep(3000); // Just sleep and print
                    System.out.println("Sleeping thread: " + Thread.currentThread().getId());
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                return 10;
            }
        });
        try {
            Future<Integer> fi = cs.take();
            System.out.println(fi.get());
        } catch (Exception e) {
            e.printStackTrace();
        }
    } finally {
        executorService.shutdown();
    }
}

或者，使用自定义threadfactory来配置执行器服务以创建守护程序线程。只有在没有正常（非daemon）线程的情况下，执行实际工作的执行人服务不是一个问题，才能做到这一点。