Future

Future

一、简介

通常情况下，我们在写多线程任务时，都是实现run方法，大家注意到run方法是没有返回值的。如果我们要用到其他线程的返回值该怎么办呢？

这里就要用到Future了。

Future是通过Callable实现的，是一种可生成结果的Runnable。当运行完成以后，可以通过Future.get获取结果。

Future.get取决于任务的状态，如果任务没有完成，则get方法一直阻塞，直到任务完成。

下面来看具体的实例

二、实例

public class Ha {
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        Callable<String> callable = () -> {
            System.out.println("分线程正在进行");
            Thread.sleep(10*1000);
            System.out.println("分线程结束");
            return "分线程完成";
        };
        ExecutorService es = Executors.newSingleThreadExecutor();
        Future<String> future = es.submit(callable);
        es.shutdown();
        System.out.println("主线程工作正在进行");
        Thread.sleep(5*1000);
        System.out.println("主线程工作结束");
        String result = future.get();
        System.out.println(result);

    }
}

首先，我们实现Callable，模拟一个工作任务，执行时间是10秒。

通过Executors创建一个单线程任务，并执行Callable。

主线程继续自己的工作，工作时间是5秒。

主线程获取分线程的任务结果，由于分线程任务是10秒，所以get方法会阻塞，直到分线程任务完成。

最后打印分线程任务结果。

执行结果如下：

• 主线程工作正在进行
• 分线程正在进行
• 主线程工作结束
• 分线程结束
• 分线程完成

上面的例子中，使用了lambda表达式，如果要运行，请使用jdk8。