Runnable、Callable、Future、FutureT

Runnable、Callable、Future、FutureTask

一：并发编程的核心

并发编程的核心问题：分工、同步和互斥。
要编写高质量的并发程序，只需要处理好分工、同步和互斥的问题即可，同步和互斥对应的就是管程模型。

二：Runnable、Callable、Future、FutureTask

1：Runnable、Callable、Future、FutureTask的UML类图

Callable与Runnable、Future、FutureTask无继承关系。
FutureTask带了Future和Runnable的功能。

Runnable....png

2：Runnable和Callable

// JDK1.0 不接受参数、无返回值，单线程、线程池均可使用。
public interface Runnable {

  public abstract void run();
  
}

// JDK 1.5 不接受参数、有返回值，仅供线程池使用。
public interface Callable<V> {

  V call() throws Exception;

}

3：Future API

// 取消任务
boolean cancel( boolean mayInterruptIfRunning);

// 判断任务是否已取消
boolean isCancelled();

// 判断任务是否已结束
boolean isDone();

// 获得任务执行结果 ---> 阻塞方法
get();

// 获得任务执行结果，支持超时 ---> 阻塞方法
get(long timeout, TimeUnit unit);

4：为什么要引入FutureTask？为什么要让FutureTask实现Runnable？

在单线程和多线程执行Task的时候，都有获取执行结果的需求，但是当使用Runnable的时候，Runnable的API是拿不到返回值的，因此可以用FutureTask类包装Runnable来拿返回值。
所以：Runnable、Callable、Future、FutureTask存在的目的是为了使用更加灵活。

获取执行结果：

• 单线程：FutureTask包装Callable和Runnable，通过FutureTask获取返回值。
• 多线程：单独使用Callable能获取返回值，FutureTask包装Callable和Runnable能获取返回值。

5：使用示例

/**
 * <p>
 * Runnable、Callable、Future、FutureTask
 * </p>
 *
 * @author: Sunny
 * @date: 2021/2/1
 * @version: v1.0.0
 */
public class TaskTest {

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        // 1：单线程 + Callable + FutureTask拿到返回结果
        FutureTask<Integer> task = new FutureTask<Integer>(() -> {
            return 1 + 1;
        });
        Thread t1 = new Thread(task);
        t1.start();
        System.out.println(task.get());

        // 2：单线程 + Runnable + T result + FutureTask拿到返回结果
        Account account = new Account();
        FutureTask<Account> task1 = new FutureTask<Account>(() -> {
            account.setName("zhangsan");
            account.setAge(3);
        }, account);
        Thread t2 = new Thread(task1);
        t2.start();
        System.out.println(task1.get().getName() + " : " + task1.get().getAge());
        System.out.println(account.getName() + " : " + account.getAge());

        // 3：线程池 + Callable + Future拿到返回结果
        ExecutorService service = Executors.newSingleThreadExecutor();
        Future<Integer> future = service.submit(() -> 1 + 1);
        System.out.println(future.get());

        // 4：线程池 + Runnable + Future拿不到返回结果
        Future<?> future1 = service.submit(() -> System.out.println(1));
        // Runnable 不接受返回值，因此其值为null
        System.out.println(future1.get());

        // 5：线程池 + Runnable +  T result + Future拿到返回结果
        Account account1 = new Account();
        Future<Account> future2 = service.submit(() -> {
            account1.setName("xiaoming");
            account1.setAge(4);
        }, account1);
        System.out.println(future2.get().getName() + " : " + future2.get().getAge());
        System.out.println(account1.getName() + " : " + account1.getAge());
        service.shutdown();
    }

    @Data
    public static class Account {
        private String name;
        private Integer age;
    }

}