Future Clalback使用案例

package com.juc.threadpool;

import java.util.concurrent.*;

/**
 * Created by Administrator on 2018/6/28.
 */
public class FutureCallBack {

    public static void main(String[] args) throws ExecutionException, InterruptedException {

        Callable<Integer> callable = () -> {
            TimeUnit.MILLISECONDS.sleep(3000);
            return 3;
        };

        FutureTask futureTask = new FutureTask(callable);
        FutureTask futureTask2 = new FutureTask(new MyTask());
        new Thread(futureTask).start();

        System.out.println(futureTask.get());//阻塞
        System.out.println("ssssssssssssssssssssss");
        new Thread(futureTask2).start();
        System.out.println(futureTask2.get());//阻塞
        System.out.println("ssssssssssssssssssssss");
        if(futureTask.isDone()){
            new Thread(futureTask2).start();
        }
        System.out.println(futureTask2.get());//阻塞


        //线程池使用
        ExecutorService executorService = Executors.newSingleThreadExecutor();
         executorService.submit(futureTask);
        System.out.println(futureTask.get());
        executorService.shutdown();
    }

    static class MyTask implements Callable<Integer> {

        @Override
        public Integer call() throws Exception {
            Thread.sleep(1000);
            return 1;
        }
    }

}