【JUC】五、线程的第三种创建方式 Callable

深碍√TFBOYSˉ_ 2024-02-18 10:34 52阅读 0赞

#### 文章目录 ####

*  1、Callable概述
 *  2、FutureTask

Java基础中，了解到的创建线程的两种方式为：

*  继承Thread类
 *  实现Runnable接口

除了以上两种，还可以通过：

*  Callable接口（since JDK1.5）
 *  线程池方式

## 1、Callable概述 ##

前面的Thread类或者Runnable接口方式创建线程，线程终止时，即run方法运行结束时，无法使线程返回结果，而Callable接口的优势正在于此。

![在这里插入图片描述][87d8a8f8a2064905832989c4eb54d167.png]

而java.lang.Runnable是void run( ) 方法：

![在这里插入图片描述][c8d583b74c4b43909e0fc7a0df15dc55.png]

查看[文档][Link 1]可以发现Thread的构造方法中，没有传Callable类型形参的，那就找个中间类：

![在这里插入图片描述][a592e5ca29b4444c9a66e121147bef7b.png]  
Thread可以传入Runnable，Runnable有个实现类叫FutureTask，它的构造方法可以传Callable，这就是个Thread和Callable的中间人。

![在这里插入图片描述][16ec2c4958c54e5080806f93f9d2ba4d.png]

## 2、FutureTask ##

传入一个可调用的任务对象Callable，创建一个 FutureTask，一旦运行就执行给定的 Callable。

public FutureTask(Callable<V> callable)

关于FutureTask的理解，就是一个`可取消的异步计算`，单开一个线程去干其他事儿，到时候活儿干完了我在其它线程获取结果就行。这一点在之前的Runnable是实现不了的，它的run方法是void类型。

> **举个现实生活的例子：**  
>   
> 老师在上课（线程A），突然口渴了（需要有一个其他计算任务），但老师不好停下课中途去买水，于是让班长一个人出去给他买水（单开一个线程），他继续上课，等班长回来，他就直接喝（计算完成后，在当前线程直接get另一线程的运行结果）。当然老师可能中途想到万一遇到校长就不妙了，于是在窗外喊住了班长，不让买了（计算结果未完成前，可以取消结果），也可能中途是想告诉班长不买水了，买包烟，于是也在窗外喊住了班长（计算结果未完成前，可以重新开始）。当然，如果这之前班长已经卖回来了，那老师就只能喝水了（一旦计算完成，就不能再重新开始或取消计算）。  
> ![在这里插入图片描述][f2c12674a2ab423fa01f11cbcc93e402.png]

FutureTask类的常用方法

*  取消计算，若无法取消任务，则返回 false

public boolean cancel(boolean mayInterruptIfRunning)

*  查询计算是否完成，FutureTask正常终止、异常或取消而完成均返回true

public boolean isDone()

*  获取计算结果

public V get()
    //重载，可传入一个最大等待时间

写个demo：

/**
     * Runnable
     */
    class MyThread1 implements Runnable{
        
        @Override
        public void run() {
        
    
        }
    }
    
    /**
     * Callable
     */
    class MyThread implements Callable<String>{
        
        @Override
        public String call() throws Exception {
        
            return "200";
        }
    }

public class Demo1 {
        
    
        public static void main(String[] args) throws ExecutionException, InterruptedException {
        
        
            FutureTask<String> futureTask1 = new FutureTask<>(new MyThread());
            
            FutureTask<String> futureTask2 = new FutureTask<>(() -> {
        
                System.out.println(Thread.currentThread().getName() + " --> come in callable");
                return "1024";
            });
            
            new Thread(futureTask2,"t1").start();
            
            while (!futureTask2.isDone()){
           //futuretask2未计算完成前，一直打印wait....
                System.out.println("wait.......");
            }
            
            System.out.println(futureTask2.get());  //在主线程中首次获取futuretask2所在线程的计算结果
            
            System.out.println(futureTask2.get());   //第二次获取计算结果
            
            System.out.println(Thread.currentThread().getName() + " --> come over");
        }
    }

运行：

![在这里插入图片描述][f5bb297527f84e7fa57b460e34548ff5.png]

在其他FutureTask所在线程中获取下另外FutureTask所在线程的计算结果：

/**
     * Callable
     */
    class MyThread2 implements Callable<String>{
        
        @Override
        public String call() throws Exception {
        
            System.out.println(Thread.currentThread().getName() + " --> come in callable");
            return "200";
        }
    }
    public class Demo1 {
        
    
        public static void main(String[] args) throws ExecutionException, InterruptedException {
        
    
            FutureTask<String> futureTask1 = new FutureTask<>(new MyThread2());
            FutureTask<String> futureTask2 = new FutureTask<>(() -> {
        
                System.out.println(Thread.currentThread().getName() + " --> come in callable");
                System.out.println("在futureTask2所在线程中获取futureTask1所在线程的计算结果：" + futureTask1.get());
                return "1024";
            });
    
            new Thread(futureTask1,"t1").start();
            new Thread(futureTask2,"t2").start();
    
            System.out.println("在main线程中获取futureTask1所在线程的计算结果：" + futureTask1.get());
            System.out.println("在main线程中获取futureTask2所在线程的计算结果：" + futureTask2.get());
            System.out.println(Thread.currentThread().getName() + " --> come over");
        }
    }

运行：

![在这里插入图片描述][75c046f3b12246349e967382ac8382cb.png]

[87d8a8f8a2064905832989c4eb54d167.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/f0745a0a8ec4476e980926f745847c3d.png
[c8d583b74c4b43909e0fc7a0df15dc55.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/a65a64249d714733968461f2cde90175.png
[Link 1]: https://tool.oschina.net/apidocs/apidoc?api=jdk-zh
[a592e5ca29b4444c9a66e121147bef7b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/7bbf09647102495b8ba0149138ac0f84.png
[16ec2c4958c54e5080806f93f9d2ba4d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/40a40594e61042bc961878b19a92f61e.png
[f2c12674a2ab423fa01f11cbcc93e402.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/c4284f9ec8ff4b549f69b020f96f9dc5.png
[f5bb297527f84e7fa57b460e34548ff5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/f802579ab2fa476999d77ffbc3c5490b.png
[75c046f3b12246349e967382ac8382cb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/e5f09837bf444ec7989bc032205e95aa.png