JUC高级多线程_05:获取线程的第三种方式

Posted ABin-阿斌

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了JUC高级多线程_05:获取线程的第三种方式相关的知识,希望对你有一定的参考价值。

我是 ABin-阿斌:写一生代码,创一世佳话,筑一揽芳华。 如果小伙伴们觉得我的文章有点 feel ,那就点个赞再走哦。
在这里插入图片描述

获取线程的第三种方式 : Callable接口

1 . 前言

1. 有几种获取多线程的方式:

  • 答:
    • 传统的是继承 Thread 类和实现 Runnable 接口
    • jdk5 以后又有实现 Callable 接口和 java 的线程池获得

2. 以下两种获得线程的方式的异同:

class MyThread1 implements Runnable{
    @Override
    public void run() {
    }
}

class MyThread2 implements Callable<Integer>{
    @Override
    public Integer call() throws Exception {
        return null;
    }
}


  • 答:
    • 两种方式重写的方法不同,Runnable 重写的是: run 方法;Callable 重写的是: call 方法
    • 是否有返回值,Runnable: 没有(可定义的返回值类型);Callable:
    • 是否抛异常,Runnable: 不抛;Callable:

2 . 使用

1. 重写 call 方法

class MyThread implements Callable<Integer>{
    @Override
    public Integer call() throws Exception {
        System.out.println("==== call被执行了... ====");

        return 1024;
    }
}

2.创建线程

  • 之前 Runable 接口创建线程使用的是 new Thread(Runnable 接口的实现, name).start(),但是查找 jdk 并没有一个参数是 Callable 的构造方法

  • 所以就需要迂回一下,需要传入一个 Callable 接口的实现,但只有 Runnable 作为参数的构造方法,那就要找到一个其他的实现类和 CallableRunnable 都有关系

  • 比如: 我们去租房,我们不认识房东,但是我们可以找中介介绍,利用 java 多态,一个类可以实现多个接口

  • 按照以上思路就找到了一个类 —— FutureTask,它即实现了 Runnable 接口,又有一个 Callable 作为参数的构造方法

public static void main(String[] args) {
        // 调用线程,MyThread 类上面写过
        FutureTask futureTask = new FutureTask(new MyThread());

        new Thread(futureTask,"线程一:").start();


    }

3.获取返回值

public class JUC06_Callable {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        // 调用线程
        // 创建对象
        FutureTask futureTask = new FutureTask(new MyThread());
        // 表达式
//        FutureTask futureTask = new FutureTask(
//	                () -> {System.out.println("==== 进入 ====");
//	                return 1024;
                });
        new Thread(futureTask,"线程一:").start();
        // 获得返回值
        System.out.println(futureTask.get());
    }
}
// Callable 后的泛型写什么类型,就返回什么类型
class MyThread implements Callable<Integer>{
    @Override
    public Integer call() throws Exception {
        System.out.println("==== callb被执行了... ====");

        return 1024;
    }
}

3 . 原理

1. 简述

  • FutureTask (未来的任务),用它就干一件事,异步调用

  • main方法就像一个冰糖葫芦,一个个方法由 main 串起来。

  • 会出现的问题: 正常调用挂起堵塞问题

  • 例子:

    • 老师上着课,口渴了,去买水不合适,讲课线程继续,我可以单起个线程找班长帮忙买水,
      水买回来了放桌上,我需要的时候再去get。
    • 4个同学,A算1+20,B算21+30,C算31*到40,D算41+50,是不是C的计算量有点大啊,
      FutureTask单起个线程给C计算,我先汇总ABD,最后等C计算完了再汇总C,拿到最终结果
    • 读书那会考试必杀技:会做的先做,不会的放在后面做

2. 解释

  • 在主线程中需要执行比较耗时的操作时,但又不想阻塞主线程时,可以把这些作业交给 Future 对象在后台完成
  • 当主线程将来需要时,就可以通过 Future 对象获得后台作业的计算结果或者执行状态。
  • 一般 FutureTask 多用于耗时的计算,主线程可以在完成自己的任务后,再去获取结果。
  • 仅在计算完成时才能检索结果;如果计算尚未完成,则阻塞 get 方法,不会执行主线程后面的任务。
  • 一旦计算完成,就不能再重新开始或取消计算。
  • get 方法获取结果只有在计算完成时获取,否则会一直阻塞直到任务转入完成状态,然后会返回结果或者抛出异常。
  • 第二次调用同一个 FutureTask 线程,不会执行,因为第一次执行完后,就把结果存入缓存后面再掉,就直接从缓存读取

3. 结论

  • 同一个 FutureTask 只会只调用一次
  • get方法放到最后

以上是关于JUC高级多线程_05:获取线程的第三种方式的主要内容,如果未能解决你的问题,请参考以下文章

JUC高级多线程_10:Future异步回调的具体介绍与使用

JUC高级多线程_06:多线程下得常用辅助类

JUC高级多线程_02:线程间的通信

JUC高级多线程_01:基础知识回顾

JUC高级多线程_04:高并发下集合类的具体使用

JUC高级多线程_03:关于多线程锁的八个常见问题