当前位置：网站首页>【多线程】——Callable创建多线程

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

2022-07-29 11:50:00 【51CTO】

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

回顾

两种经典的线程创建方式

1、继承Thread类创建线程类

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

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

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

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

(ps:这两种创建方式在《【多线程】——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());
       
    }
       
}
      
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.