为了保证系统响应迅速，需要寻找一种方法能够使调取接口能够异步执行，而Java正好提供了类似的方法，在java.util.concurrent中包含了Future相关的类，运用其中的一些类可以进行异步计算，以减少主线程的等待时间。比如启动一个main方法，main中又包含了若干个其它任务，在不使用Java future的情况下，main方法中的任务会同步阻塞执行，一个执行完成后，才能去执行另一个；如果使用java future，则main方法中的任务会异步执行，main方法不用等待一个任务的执行完成，只需往下执行就行。一个任务的执行结果又该怎么获取呢?这里就需要用到Future接口中的isDone()方法来判断任务是否执行完，如果执行完成则可获取结果，如果没有完成则需要等待。 **可见虽然主线程中的多个任务是异步执行，但是无法确定任务什么时候执行完成，只能通过不断去监听以获取结果，所以这里是阻塞的。这样，可能某一个任务执行时间很长会拖累整个主任务的执行。**

还是那句话，废话不多说，直接上代码：

package com.aplus.controller;

import lombok.extern.slf4j.Slf4j;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import java.util.Random;

import java.util.concurrent.Callable;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.Future;

/**

* @author whb

*/

@Slf4j

@RestController

@RequestMapping(value = "/api/guava")

public class GuavaController {

public static final ExecutorService service = Executors.newCachedThreadPool();

public static void main(String[] args) throws Exception {

long start = System.currentTimeMillis();

// 任务1

Future booleanTask = service.submit(new Callable() {

@Override

public Boolean call() throws Exception {

Thread.sleep(10000);

return true;

}

});

// 任务2

Future stringTask = service.submit(new Callable() {

@Override

public String call() throws Exception {

Thread.sleep(3000);

return "Hello World";

}

});

// 任务3

Future integerTask = service.submit(new Callable() {

@Override

public Integer call() throws Exception {

Thread.sleep(2000);

return new Random().nextInt(100);

}

});

while (true) {

if (booleanTask.isDone() && !booleanTask.isCancelled()) {

Boolean result = booleanTask.get();

System.err.println("任务1-10s： " + result);

break;

}

}

while (true) {

if (stringTask.isDone() && !stringTask.isCancelled()) {

String result = stringTask.get();

System.err.println("任务2-3s： " + result);

break;

}

}

while (true) {

if (integerTask.isDone() && !integerTask.isCancelled()) {

Integer result = integerTask.get();

System.err.println("任务3-2s：" + result);

break;

}

}

// 执行时间

System.err.println("time: " + (System.currentTimeMillis() - start));

}

}

解释一波：

启动一个线程池，有三个线程和三个任务，分别是线程1，线程2，线程3；线程1执行任务1(耗时10s)，线程2执行任务2(耗时3s)，线程3执行任务3(耗时2s)；

Thread1 ——> Task1 10s

Thread2 ——> Task2 2s

Thread3 ——> Task3 3s

我们运行程序看效果：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMTAxNjc1_size_16_color_FFFFFF_t_70][]

因为我们一开始用 Thread1.get() 获取第一个线程的结果时，是阻塞的，而且我们假定任务1执行了10s钟，导致了线程2(3s就执行完任务)和线程3(2s就执行完任务)都执行完了任务，也不打印出来。那在实际业务中，这种方法肯定是不可取的。

所以接下来我们引入 [Guava Future](/article/details/1011093225221856)

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMzMTAxNjc1_size_16_color_FFFFFF_t_70]: /images/1602422945647.png