Java多线程Callable源码详解

亦凉 2023-10-02 20:37 0阅读 0赞

#### Java多线程Callable源码详解 ####

*  Callable 与 Runnable 对比
 *  Callable 源码分析

--------------------

## Callable 与 Runnable 对比 ##

> 利用线程对1~100求和,并返回sum值输出在控制台中

// 使用Runnable创建线程
    
    public class Runnable_Callable {
        
        public int sum = 0;
        public static void main(String[] args) throws InterruptedException {
        
            Runnable_Callable rc = new Runnable_Callable();
            Thread t1 = new Thread(new Runnable() {
        
                @Override
                public void run() {
        
                    int sum = 0;
                    for (int i = 0; i <= 100; i++) {
        
                        sum += i;
                    }
                   rc.sum  = sum;
                }
            });
            t1.start();
            t1.join();
            System.out.println(rc.sum);
        }
    }

> 可以看到,要想返回sum值,非常麻烦,所以,利用Callable可以快速的获得返回值.

Callable<Integer> callable = new Callable<Integer>() {
        
                @Override
                public Integer call() throws Exception {
        
                    int sum = 0;
                    for (int i = 0; i <= 100; i++) {
        
                        sum += i;
                    }
                    return sum;
                }
            };
            FutureTask<Integer> futureTask = new FutureTask<>(callable);
            Thread t2 = new Thread(futureTask);
            t2.start();
    
            Integer sum = futureTask.get();
            System.out.println(sum);

> 通过Callable,可以将计算的值直接返回出来.  
>   
> 下面源码分析!!

--------------------

## Callable 源码分析 ##

几个问题:

1.  `Callable`没有`run`,为什么可以用Callable创建一个线程.
2.  为什么`Callable`有返回值
3.  `FutureTask`起到了什么作用

--------------------

1.观察Thread构造方法  
![在这里插入图片描述][d4302556e4784d228f2d8ca5584d0182.png]  
观察发现,Thread并没有参数为`Callable`类型的参数,所以利用`FutureTask`包装,而`FutureTask`实现了`RunnableFuture<V>`接口,`RunnableFuture<V>`又实现了`Runnable`接口.所以,可以传入`FutureTask`作为`Thread`的参数.  
![在这里插入图片描述][db54bb60aca04a24802279eadfc8014d.png]

![在这里插入图片描述][378faed6a0b343df9df327bc0689e240.png]  
2.对于`FutureTask`类  
![在这里插入图片描述][e44598f0dfe343899557d700fedeecc6.png]  
则可以接收一个`Callable`类的对象

3.当线程启动时,会调用`FutureTask`的`run()`方法启动线程,  
![在这里插入图片描述][52439e1c8cc64a77a0fedf70af48ce67.png]  
![在这里插入图片描述][bd771de45b6142c3a59e18bc0f5b61c9.png]  
![在这里插入图片描述][4347cb1da36d4a519de45183ea388a3a.png]

> 此处有解锁步骤,猜测获取返回值时会存在加锁

**get()方法**  
![在这里插入图片描述][84d2d0c5c62d41fab3b546d3843f70c8.png]  
![在这里插入图片描述][f6dec6f83d0a4571850bb5b2948806e7.png]  
![在这里插入图片描述][261c3d8af4454c5a8e5796d803e7f4a5.png]

--------------------

> 总结:当`Thread`调用`start()`方法时,自动调用`FutureTask`的`run()`方法,由`run()`方法调用`call()`方法,并将返回值记录下来保存在`outcome`全局变量当中  
> 当在`main()`方法调用`get()`方法获取结果时,会进入一个循环判断当中,当结果还没被计算出来,会调用`LockSupport.park()`使线程阻塞,直到结果被保存到`outcome`当中,调用`LockSupport.unpark()`解锁,此时`get()`方法不在阻塞,返回出结果.  
> ![在这里插入图片描述][45f366988e0e401f809a42b356549fe1.png]

[d4302556e4784d228f2d8ca5584d0182.png]: https://img-blog.csdnimg.cn/d4302556e4784d228f2d8ca5584d0182.png
[db54bb60aca04a24802279eadfc8014d.png]: https://img-blog.csdnimg.cn/db54bb60aca04a24802279eadfc8014d.png
[378faed6a0b343df9df327bc0689e240.png]: https://img-blog.csdnimg.cn/378faed6a0b343df9df327bc0689e240.png
[e44598f0dfe343899557d700fedeecc6.png]: https://img-blog.csdnimg.cn/e44598f0dfe343899557d700fedeecc6.png
[52439e1c8cc64a77a0fedf70af48ce67.png]: https://img-blog.csdnimg.cn/52439e1c8cc64a77a0fedf70af48ce67.png
[bd771de45b6142c3a59e18bc0f5b61c9.png]: https://img-blog.csdnimg.cn/bd771de45b6142c3a59e18bc0f5b61c9.png
[4347cb1da36d4a519de45183ea388a3a.png]: https://img-blog.csdnimg.cn/4347cb1da36d4a519de45183ea388a3a.png
[84d2d0c5c62d41fab3b546d3843f70c8.png]: https://img-blog.csdnimg.cn/84d2d0c5c62d41fab3b546d3843f70c8.png
[f6dec6f83d0a4571850bb5b2948806e7.png]: https://img-blog.csdnimg.cn/f6dec6f83d0a4571850bb5b2948806e7.png
[261c3d8af4454c5a8e5796d803e7f4a5.png]: https://img-blog.csdnimg.cn/261c3d8af4454c5a8e5796d803e7f4a5.png
[45f366988e0e401f809a42b356549fe1.png]: https://img-blog.csdnimg.cn/45f366988e0e401f809a42b356549fe1.png