6.2Java多线程Callable接口

Posted 俊king

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了6.2Java多线程Callable接口相关的知识,希望对你有一定的参考价值。

6.2Java多线程Callable接口

Callable接口方法图示

与Runnable接口的run方法比较的优势:

  • Callable接口可以向外抛出异常--->异常监测

  • call方法可以有返回值,run方法没有返回值

与Runnable接口的run方法比较的劣势:

  • 使用起来需要创建执行服务

  • 使用起来需要使用ThreadPool线程池

  • 需要提交到服务里面获取未来的值

  • 再通过get方法返回

  • 最后需要关闭服务

创建线程的方式三:实现callable接口,重写call方法

package iostudy.thread;

import java.util.concurrent.*;

/**
* 使用Callable接口实现图片下载
* @since JDK 1.8
* @date 2021/6/2
* @author Lucifer
*/
public class CDownload implements Callable<Boolean> {
   /*因为使用Callable接口,其接口又返回值。默认是Object,可以通过修改泛型的方式修改返回值类型*/
   /*定义两个属性*/
   private String url; //远程资源路径名称
   private String name; //本地存储资源的名称

   /*构造器*/
   public CDownload(String url, String name){
       this.url = url;
       this.name = name;
  }

   /*重写call方法--->返回泛型数据,抛出异常*/
   public Boolean call() throws Exception{
       WebDownload wd = new WebDownload();
       wd.download(url, name);
       System.out.println(name);
       return true;
  }

   public static void main(String[] args) throws ExecutionException, InterruptedException {
       /*启动call方法的步骤*/
       /*
       1、创建目标对象
       2、创建执行服务
       3、提交执行
       4、获取结果
       5、关闭服务
        */

       //创建目标对象
       CDownload cd1 = new CDownload("https://gimg2.baidu.com/image_search/src=http%3A%2F%2Fb-ssl.duitang.com%2Fuploads%2Fitem%2F201601%2F29%2F20160129170734_PhxvB.thumb.700_0.jpeg&refer=http%3A%2F%2Fb-ssl.duitang.com&app=2002&size=f9999,10000&q=a80&n=0&g=0n&fmt=jpeg?sec=1625197795&t=7f3d142f36283c64779838e6dee5a17e", "GodFather.jpg");
       CDownload cd2 = new CDownload("https://gimg2.baidu.com/image_search/src=http%3A%2F%2Fimg01.sogoucdn.com%2Fapp%2Fa%2F200765%2Fced08837008d4d09bf3f352eaa5bfb4c&refer=http%3A%2F%2Fimg01.sogoucdn.com&app=2002&size=f9999,10000&q=a80&n=0&g=0n&fmt=jpeg?sec=1625197866&t=2be2df9616cdfa35271de4b9d407c5e4", "YoungGodFather.jpg");

       //创建执行服务--->两个服务(cd1、cd2)
       ExecutorService service = Executors.newFixedThreadPool(2); //创建线程池中的线程数量

       //提交执行
       Future<Boolean> result1 = service.submit(cd1);
       Future<Boolean> result2 = service.submit(cd2);

       //获取结果--->每一个服务都要获取结果
       boolean r1 = result1.get();
       boolean r2 = result2.get();

       //释放资源--->关闭服务
       service.shutdown();
  }
}

通过callable接口模拟比赛

package iostudy.thread;


import java.util.concurrent.*;

/**
* 模拟比赛,重写call方法,返回整数值
* @since JDK 1.8
* @date 2021/6/2
* @author Lucifer
*/
public class CRacer implements Callable<Integer> {

   /*定义胜利者*/
   private String winner;

   /*重写call方法*/
   @Override
   public Integer call() throws Exception{
       /*循环步数*/
       for (int steps = 1; steps < 100; steps++){
           //模拟兔子休息
           if (Thread.currentThread().getName().equals("rabbit") && steps%10==0){
               /*让线程休眠*/
               Thread.sleep(100);
          }
           /*输出每个代理商的步数*/
           System.out.println();
           //判断比赛是否结束
           boolean flag = gameOver(steps);
           if (flag){
               /*返回步数*/
               return steps;
          }
      }
       return null;
  }

   /**
    * 胜利条件判断的方法
    * @param steps     步数
    * @return
    */
   public boolean gameOver(int steps){
       if (winner!=null){
           /*存在胜利者,返回真*/
           return true;
      }else {
           /*先到达一百步的人*/
           if (steps == 100){
               /*获得胜利者的名字*/
               winner = Thread.currentThread().getName();
               /*输出*/
               System.out.println("Winner is:" + winner);
               /*返回真*/
               return true;
          }
      }
       return false;
  }

   /**
    * 主线程启动方法
    */
   public static void main(String[] args) throws ExecutionException, InterruptedException {
       /*启动call方法的步骤*/
       /*
       1、创建目标对象
       2、创建执行服务
       3、提交执行
       4、获取结果
       5、关闭服务
        */

       /*创建目标对象--->实现类对象*/
       CRacer cRacer = new CRacer();

       /*创建执行服务*/
       ExecutorService service = Executors.newFixedThreadPool(2); //使用线程池方法执行服务

       /*提交执行*/
       Future<Integer> result1 = service.submit(cRacer);
       Future<Integer> result2 = service.submit(cRacer);

       /*获取结果*/
       Integer r1 = result1.get();
       Integer r2 = result2.get();
       System.out.println(r1 + "--->" + r2);

       /*关闭服务*/
       service.shutdown();
  }
}

 

以上是关于6.2Java多线程Callable接口的主要内容,如果未能解决你的问题,请参考以下文章

java多线程 -- 创建线程的第三者方式 实现Callable接口

Java并发多线程编程——Callable和Runnable接口的区别

Java多线程之Callable接口的实现

java 多线程-实现Callable接口

Java多线程详解多线程龟兔赛跑实力及实现Callable接口

Java多线程之Callable接口的实现