java.util.concurrent.Future.get()没有返回

Question

我有以下Java代码:

final Future future = exeService.submit(
    new Runnable() {
        public void run() {
            myObject.doSomething();
        }
    }
);

future.get();

在哪里exeService是一个实例

java.util.concurrent.ExecutorService

问题是myObject.doSomething()永远不会返回,因此future.get()永远不会返回.

但是,如果我将调用替换submit为execute这样的调用:

exeService.execute(
    new Runnable() {
        public void run() {
            myObject.doSomething();
        }
    }
);

呼叫myObject.doSomething()确实返回.我不知道这是否重要,但这doSomething()是一种void方法.

为什么doSomething()在使用execute时完成但在使用时没有submit？

另外,我不需要使用Future.get(); 这似乎是最自然的方式.(我也遇到了同样的问题CountdownLatch.)重点是我需要等待才能doSomething()继续完成,并且由于复杂的原因我不会进入这里,我需要在一个单独的线程上启动它.如果有另一种方法可以做到这一点,那就没问题了.

Answer 1

与在Executor.execute()Javadoc中一样:

在将来的某个时间执行给定的命令.该命令可以在Executor实现的判断下在新线程,池化线程或调用线程中执行.

因此,该方法execute()立即返回,让您无法查询已提交任务的状态.

另一方面ExecutorService.submit():

提交Runnable任务以执行并返回表示该任务的Future.Future的get方法将在成功完成后返回null.

该的Future.get()将返回唯一成功赛区之后,所以从来没有在您的案件.

这在Future.get()文档中进一步说明:

如果需要等待计算完成,然后检索其结果.

Answer 2

我创建了一个SSCCE:

package com.stackoverflow.q2585971;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class Test {

    public static void main(String args[]) throws Exception {
        ExecutorService executor = Executors.newCachedThreadPool();
        Future<?> future = executor.submit(
            new Runnable() {
                public void run() {
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        System.out.println("Epic fail.");
                    }
                }
            }
        );

        System.out.println("Waiting for task to finish..");
        future.get();
        System.out.println("Task finished!");
        executor.shutdown();
    }

}

它工作得很好.它首先打印

Waiting for task to finish..

然后一秒钟后你就会看到

Task finished!

所以,你的问题出在其他地方.我会在这里复制我对你问题的评论:

你的问题很混乱.第一个结构应该可行.困惑在于"回归".你不只是意味着"完成"或"执行"吗？您的混淆似乎是基于future.get() 实际等待runnable完成的事实,因此将阻止线程并阻止它future.get()在行之后执行代码的残余.