JUC系列（六） | Callable和Future接口详解&使用、FutureTask应用 获取异步线程返回值

@FunctionalInterface
public interface Callable<V> {
    V call() throws Exception; //计算结果，如果无法计算则抛出异常。
}

/**
 * @Author: crush
 * @Date: 2021-08-19 16:14
 * version 1.0
 */
public class Demo1 {
    public static void main(String[] args) {
        new Thread(new RunnableDemo1(),"AA").start();

        FutureTask<Integer> futureTask = new FutureTask<>(new CallableDemo<Integer>());
        new Thread(futureTask,"BB").start();
        // 在线程执行完后，我们可以通过futureTask的get方法来获取到返回的值。
        System.out.println(futureTask.get());
    }
}
class RunnableDemo1 implements  Runnable{
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName()+"::通过实现Runnable来执行任务");
    }
}
class CallableDemo<Integer> implements Callable<java.lang.Integer> {

    @Override
    public java.lang.Integer call() throws Exception {
        System.out.println(Thread.currentThread().getName()+"::通过实现Callable接口来执行任务，并返回结果！");
        return 1024;
    }
}
/**
 * AA::通过实现Runnable来执行任务
 * BB::通过实现Callable接口来执行任务，并返回结果！
 * 1024
 */

public interface Future<V> {

    boolean cancel(boolean mayInterruptIfRunning); //尝试取消此任务的执行。

    boolean isCancelled();//如果此任务在正常完成之前被取消，则返回true 

    boolean isDone(); //如果此任务完成，则返回true 。 完成可能是由于正常终止、异常或取消——在所有这些情况下，此方法将返回true 

    V get() throws InterruptedException, ExecutionException; //获得任务计算结果

    V get(long timeout, TimeUnit unit) 
        throws InterruptedException, ExecutionException, TimeoutException;//可等待多少时间去获得任务计算结果
}

/**
 * @Author: crush
 * @Date: 2021-08-19 16:14
 * version 1.0
 */
public class Demo1 {
    public static void main(String[] args) throws ExecutionException, InterruptedException {

        FutureTask<Integer> futureTask = new FutureTask<>(new CallableDemo<Integer>());

        new Thread(futureTask,"BB").start();
        System.out.println(futureTask.get());
        // 我们来测试一下任务是否已经完成
        System.out.println(futureTask.isDone());


    }
}
class CallableDemo<Integer> implements Callable<java.lang.Integer> {

    @Override
    public java.lang.Integer call() throws Exception {
        System.out.println(Thread.currentThread().getName()+"::通过实现Callable接口来执行任务，并返回结果！");
        return 1024;
    }
}

/**
 * @Author: crush
 * @Date: 2021-08-19 18:44
 * version 1.0
 */
public class CallableDemo2 {

    public static void main(String[] args) throws InterruptedException, ExecutionException, TimeoutException {
        CallableAndFutureTest callableAndFutureTest = new CallableAndFutureTest();
        FutureTask<String> task = new FutureTask<>(callableAndFutureTest);
        new Thread(task).start();
        
//        System.out.println("尝试取消任务，传true表示取消任务，false则不取消任务::"+task.cancel(true));

        System.out.println("判断任务是否已经完成::"+task.isDone());

        //结果已经计算出来，则立马取出来，如若摸没有计算出来，则一直等待，直到结果出来，或任务取消或发生异常。
        System.out.println("阻塞式获取结果::"+task.get());

        System.out.println("在获取结果时，给定一个等待时间，如果超过等待时间还未获取到结果，则会主动抛出超时异常::"+task.get(2, TimeUnit.SECONDS));

    }
}

class CallableAndFutureTest implements Callable<String> {
    @Override
    public String call() throws Exception {
        String str="";
        for (int i=0;i<10;i++){
            str+=String.valueOf(i);
            Thread.sleep(100);
        }
        return str;
    }
}