package com.basic;

import java.util.concurrent.*;

/**
 * @program JavaBooks
 * @description: future
 * @author: mf
 * @create: 2020/01/01 14:18
 */

public class T23 {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        FutureTask<Integer> task = new FutureTask<>(() -> {
            TimeUnit.MILLISECONDS.sleep(500);
            return 1000;
        });

        new Thread(task).start();

        System.out.println(task.get()); // 阻塞

        ExecutorService service = Executors.newFixedThreadPool(5);

        Future<Integer> f = service.submit(() -> {
            try {
                TimeUnit.MILLISECONDS.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return 1;
        });
//        System.out.println(f.get());
        System.out.println(f.isDone());
        System.out.println(f.get());
        System.out.println(f.isDone());
        service.shutdown();
    }
}