【多线程】——Callable创建多线程

亦凉 2022-05-22 20:20 436阅读 0赞

之前小编的博客简单介绍了两种创建线程的方式，随着小编工作过程对这一部分的深入，对这一部分有更深入的理解，也知道其他创建多线程方式，在原来的基础在深入一下！

# 回顾 #

两种经典的线程创建方式

1、继承Thread类创建线程类

2、实现Runnable接口创建线程类

演示一种利用lambda表达式创建线程的方式

public static void main(String[] args) { Thread th = new Thread(()->{ System.out.println("利用Runnable接口"); }); th.start(); }

之所以能这样写应为Runnable接口为函数式接口，其中只有一个run()方法，相比之前匿名函数的写法，又简便了很多。

(ps:这两种创建方式在[《【多线程】——Thread VS Runnable》][Thread VS Runnable]中均已详细说明，此处不再详细说明）

# 方式三 #

使用Callable和Future创建线程

从Java5开始，Java提供了Callable接口，而且是函数式接口，从应用角度Callable就是Runnable接口的增强版，Callable接口提供一个call()方法作为线程执行体，与Runnable中run()方法类似，但是比run()方法更强大而且Callable接口并不是Runnable接口的子接口。

1、call()方法可以有返回值

2、call()方法可以声明抛出异常

问题来了，那Callable对象不能直接作为Thread的target，而且call()中还有返回值，也不是直接别调用，作为线程执行体被调用，该怎么样和Thread配合使用呢？

Java5提供Future接口来接收Callable接口里call()方法的返回值，并且为Future提供了一个FutureTask实现类，该实现类不仅实现了Future接口还实现了Runnable接口，这样就能作为Thread的target，与Thread结合了。

**Future中提供几个方法配合Callable接口使用**

1、V get():返回Callable接口中call()的返回值。调用该方法将导致程序堵塞，必须等到子线程结束才会得到返回值。

2、boolean cancel(boolean mayInterruptIfRunning):试图取消Future里关联的Callable任务

3、boolean isCancelled():如果在Callable任务正常完成前被取消，则返回true

4、boolean isDone():如果Callable任务已完成，则返回true。

## Callable使用方式 ##

1、创建Callable接口的实现类，并实现call()方法，该call()方法将作为线程执行体，且该call()方法有返回值,再创建Callable实现类的实例

2、使用FutureTask对象包装Callable对象

3、使用FutureTask作为Thread的target创建并启动新线程

4、调用FutureTask的get()来获取子线程的返回值。

demo展示Callable使用方式

package com.jia.thread;
    
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.FutureTask;
    
    /**
     * @author 贾文静 on 2018/6/10.
     * Describe
     */
    public class CallableTask {
        public static void main(String[] args) throws ExecutionException, InterruptedException {
            FutureTask <Integer> futureTask = new FutureTask <>((Callable <Integer>) () -> {
                int i = 0;
                for (; i < 100; i++) {
                    System.out.println(Thread.currentThread().getName() + i);
                }
    //        作为Callable的返回值i
                return i;
            });
            for (int i = 0; i < 100; i++) {
                System.out.println(i);
                if (i==20) {
                    //利用Callable和FutureTask作为目标对象启动线程
                    new Thread(futureTask,"有返回值的线程").start();
                }
            }
    //        接收FutureTask的返回值
            System.out.println("子线程的返回值:" + futureTask.get());
        }
    }

# Callable和Runnable不同 #

1、Callable规范的方式是call(),Runnable规定方式是run()。其中Runnable提交给Thread来包装下，直接启动一个线程来执行。而Callable一般提交给ExecuteService来执行

2、Callable的任务来执行可以有返回值，但是Runnable不能有返回值

3、call方法可以抛出异常，run方法不能

4、运行Callable任务可以拿到一个Future对象，表示异步计算的结果。它提供了检查计算是否完成的方法，以等待计算的完成，并检索计算的结果。通过Future对象可以了解任务执行情况，可取消任务的执行，还可获取执行结果。

关于两者更多不同展示推荐博客：[Callable,Runnable的区别及用法][Callable_Runnable]

# 总结 #

很基础内容，算是补充上篇博客的不足了！

[Thread VS Runnable]: https://blog.csdn.net/jiadajing267/article/details/71365906
[Callable_Runnable]: https://blog.csdn.net/qq_27258799/article/details/51451143