Callable and FutureTask

2024-04-22 03:04
文章标签 callable futuretask

本文主要是介绍Callable and FutureTask，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Callable

由关系图可知，Callable和Runnable一样，也是一个函数式接口，可以使用Lambda表达式

与之不同的是，其内部的call()方法可以抛出异常且能return一个返回值

 Callable<Object> callable = new Callable() {@Overridepublic Object call() throws Exception {System.out.println("执行call方法");return null;}};

FutureTask

FutureTask构造方法源码:public FutureTask(Callable<V> callable) {if (callable == null)throw new NullPointerException();this.callable = callable;this.state = NEW;       // ensure visibility of callable}public FutureTask(Runnable runnable, V result) {this.callable = Executors.callable(runnable, result);this.state = NEW;       // ensure visibility of callable}

Future接口方法

 //mayInterruptIfRunning:是否取消正在执行但还有执行完毕的任务 //true:取消任务 返回true//false:让任务执行完毕 返回falseboolean cancel(boolean mayInterruptIfRunning);//任务是否被取消boolean isCancelled();//任务是否完成 //完成可能是由于正常终止、异常或取消 --- 在所有这些情况下，此方法将返回 trueboolean isDone();//得到任务返回值，如果未执行的话会阻塞等待V get() throws InterruptedException, ExecutionException;//设置最大阻塞时间，如果超过最大阻塞时间后还是没有执行完任务，抛出TimeOutExceptionV get(long timeout, TimeUnit unit)throws InterruptedException, ExecutionException, TimeoutException;

根据上方关系图我们可知

FutureTask可以包装Runnable/Callable对象-----构造方法

FutureTask实现了Runnable接口 ，故其可以作为Runnable被线程执行

notice：线程执行的是FutureTask类包装的Callable对象下的call()方法

public static void main(String[] args) throws ExecutionException, InterruptedException {//使用Callable进行1-100相加数和Callable<Long> callable = new Callable<Long>() {@Overridepublic Long call() throws Exception {System.out.println("开始执行子线程相加内容");long sum = 0;for(int i = 1; i <= 100; i++){sum += i;}return sum;}};FutureTask<Long> futureTask = new FutureTask<>(callable);Thread t = new Thread(futureTask);//真正执行call方法的是线程 所以必须要启动线程后 call方法才会执行//t.start();//相当于t.join操作System.out.println("futureTask.get()得到call方法的函数返回值:"+futureTask.get()); //如果没有call方法内容没有执行完 get方法会一直阻塞
}

此时没有执行t.start操作，futureTask.get()方法就会一直阻塞

反之执行t.start；

  
  //使用Callable进行1-100相加数和Callable<Long> callable = new Callable<Long>() {@Overridepublic Long call() throws Exception {Thread.sleep(3000);System.out.println("开始执行子线程相加内容");long sum = 0;for(int i = 1; i <= 100; i++){sum += i;}return sum;}};FutureTask<Long> futureTask = new FutureTask<>(callable);Thread t = new Thread(futureTask);//真正执行call方法的是线程 所以必须要启动线程后 call方法才会执行t.start();long begin = System.currentTimeMillis();//相当于t.join操作System.out.println("futureTask.get()得到call方法的函数返回值:"+futureTask.get()); //如果没有call方法内容没有执行完 get方法会一直阻塞long end = System.currentTimeMillis();System.out.println("阻塞时间:"+ (end -begin));}

上述代码中，我们在call方法中休眠了三秒，由于当get方法任务没有执行完时，就会阻塞，故主线程被三秒，所以get()操作类似于join方法

get():

我们知道，当线程在休眠时被终止时，会触发sleep内部异常，在Runnable中，触发异常后并不会终止进程，而是将线程提前唤醒，且将终止标志位重新设置为false，后续的操作由程序员的代码决定 

public static void main(String[] args) {Thread t1 = new Thread(new Runnable() {@Overridepublic void run() {for(int i = 0; i < 3; i++){System.out.println("Hello World");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();System.out.println("触发skeep interrupted异常 后续执行操作由我决定");}}}});t1.start();t1.interrupt();System.out.println("线程是否被终止:"+t1.isInterrupted());}

即使触发了异常，但还是继续完成了runnable中的run方法

但在Callable中，如果线程被休眠时被唤醒，FutureTask.get()方法就会直接报错且退出程序

public static void main(String[] args) throws ExecutionException, InterruptedException {Callable<String> callable = new Callable<String>() {@Overridepublic String call() throws Exception {System.out.println("你好");Thread.sleep(1000);return "我要报错拉";}};FutureTask task = new FutureTask(callable);Thread t = new Thread(task);t.start();t.interrupt();//非正常终止 --- 休眠时终止System.out.println("isDone:"+task.isDone());System.out.println(task.get());}

但如果仅仅是启动线程(没有FutureTask.get()操作），那么不会报错，但会直接终止线程

 public static void main(String[] args) throws ExecutionException, InterruptedException {Callable<String> callable = new Callable<String>() {@Overridepublic String call() throws Exception {for(int i = 0; i < 3; i++){System.out.println("你好");Thread.sleep(1000);}return "我要报错拉";}};FutureTask task = new FutureTask(callable);Thread t = new Thread(task);t.start();t.interrupt();//非正常终止 --- 休眠时终止System.out.println("isDone:"+task.isDone());}

超时get():
 public static void main(String[] args) throws ExecutionException, InterruptedException, TimeoutException {//超时get方法Callable<String> callable = new Callable<String>() {@Overridepublic String call() throws Exception {Thread.sleep(2000);System.out.println("任务继续执行");return "ok";}};FutureTask futureTask = new FutureTask(callable);Thread t = new Thread(futureTask);t.start();//若超出时间 报TimeoutException异常 call方法中的内容继续进行  //无法取到call方法中的返回值了System.out.println(futureTask.get(1, TimeUnit.SECONDS));}

.

超时后call方法中的任务还是会继续进行，但无法通过get方法获得call方法的返回值了

cancel():
public static void main(String[] args) {Callable<Integer> callable = new Callable<Integer>() {@Overridepublic Integer call() throws Exception {int sum = 0;for(int i = 0; i <= 10; i++){sum += i;}return sum;}};FutureTask<Integer> futureTask = new FutureTask<>(callable);Thread t = new Thread(futureTask);t.start();//取消任务  参数mayInterruptIfRunning是否取消正在运行的任务  其内部实际上还是通过interrupt方法System.out.println("cancel:"+futureTask.cancel(true));//任务是否被取消System.out.println("isCancelled:"+futureTask.isCancelled());//任务是否执行完成//如果此任务已完成，则返回 true。完成可能是由于正常终止、异常或取消 -- 在所有这些情况下，此方法将返回 trueSystem.out.println("isDone:"+futureTask.isDone());}

 //取消任务  参数mayInterruptIfRunning是否取消正在运行的任务  其内部实际上还是通过interrupt方法System.out.println("cancel:"+futureTask.cancel(true));//在取消任务后 调用get方法 此时不能返回call方法返回值 且会抛出异常 退出程序System.out.println("after cancel:"+ futureTask.get());

使用线程池执行Callable
//利用线程池执行public static void main(String[] args) throws ExecutionException, InterruptedException {ExecutorService service = Executors.newFixedThreadPool(10);//execute Runnable command//submit Future<V> future//这里是Callable 只能使用submit Runnable/Callable都可以 返回值是Future<?> / 不能使用execute:RunnableFuture<String> future = service.submit(new Callable<String>() {@Overridepublic String call() throws Exception {return "Hello World";}});System.out.println(future.get());service.shutdown();}

这篇关于Callable and FutureTask的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/924678。

相关文章

【硬刚Java并发】JUC基础（五）：实现 Callable 接口

【硬刚Java并发】JUC基础（五）：实现 Callable 接口

本文是对《【硬刚大数据之学习路线篇】从零到大数据专家的学习指南(全面升级版)》的Java并发部分补充。 1 Callable 接口 Java 5.0 在 java.util.concurrent 提供了一个新的创建执行线程的方式：Callable 接口 Callable 接口类似于 Runnable，两者都是为那些其实例可能被另一个线程执行的类设计的。但是 Runnable 不会返回结果
阅读更多...
Java并发编程：Callable和Future使用

Java并发编程：Callable和Future使用

在Java中，创建线程一般有两种方式，一种是继承Thread类，一种是实现Runnable接口。然而，这两种方式的缺点是在线程任务执行结束后，无法获取执行结果。我们一般只能采用共享变量或共享存储区以及线程通信的方式实现获得任务结果的目的。 不过，Java中，也提供了使用Callable和Future来实现获取任务结果的操作。Callable用来执行任务，产生结果，而Future用来获得结果。 C
阅读更多...
【Python报错已解决】`TypeError: ‘numpy.ndarray‘ object is not callable`

【Python报错已解决】`TypeError: ‘numpy.ndarray‘ object is not callable`

引言： 在编程中，你是否遇到过尝试调用一个Numpy数组对象时出现了TypeError: 'numpy.ndarray' object is not callable的报错？这个问题通常是由于误将Numpy数组当成了一个函数来调用。接下来，我们将分析这个问题并提供解决方案。 一、问题描述： 1.1 报错示例： import numpy as np# 创建一个Numpy数组arra
阅读更多...
FutureTask通常如何使用?

FutureTask通常如何使用?

FutureTask 是一种有用的工具，用于管理并发编程中可取消的、可监听的任务。它通常被用来包装 Callable 或 Runnable 对象，并在单独的线程中执行这些任务。以下是一些使用 FutureTask 的典型场景和步骤： 1. 包装 Callable 或 Runnable 下面是基本的包装 Callable 和 Runnable 的方法： // 使用 CallableCalla
阅读更多...
Callable Future Executor

Callable Future Executor

一般通过继承Thread还有实现Runnable，都不可以有返回值,不可以声明检查异常。 Callable和Future，通过ExecutorService的submit方法执行Callable，并返回给Future，这里返回值只有一个，ExecutorService继承自Executor，通过使用Executor执行器来操作。 public class CallableAndFuture {
阅读更多...
Callable使用示例

Callable使用示例

package com.expgiga.JUC;import java.util.concurrent.Callable;import java.util.concurrent.ExecutionException;import java.util.concurrent.FutureTask;/** * 一、创建执行线程的方式三：实现Callable接口。 * 相较于实现Runnab
阅读更多...
Java多线程（二）——Callable、Future和FutureTask

Java多线程（二）——Callable、Future和FutureTask

在上一章节我们介绍了Java实现多线程最常用的两种方式，但是那两种方式实现线程的时候并不能返回线程的执行结果。然而有些场景我们需要得到线程的执行结果，比如要计算每个部门的这个月的工资，然后进行总计（假设有n个部门，计算每个部门的工资需要花费m个小时，计算总计需要k个小时）。那么有以下两种方案供选择“： n个部门工资计算和总计都安排给一个人来做，需要花费n*m+k小时；每个部门工资计算都分别安排给
阅读更多...
Python学习笔记 --- TypeError: 'unicode' object is not callable

Python学习笔记 --- TypeError: 'unicode' object is not callable

今天在debug的时候遇到了一个棘手的问题就是我在使用 type 函数的时候报错 TypeError: 'unicode' object is not callable 后经过多方判断，发现是上面存在一个名字为type的变量，这个报错的信息就是将字符串，当函数来使用了。 使用方法不对！！ 具体如下： 图一显示错误的代码：
阅读更多...
Callable 和Future

Callable 和Future

在Java5之前，线程是没有返回值的，常常为了“有”返回值，破费周折，而且代码很不好写。或者干脆绕过这道坎，走别的路了。 现在Java终于有可返回值的任务（也可以叫做线程）了。  可返回值的任务必须实现Callable接口，类似的，无返回值的任务必须Runnable接口。 执行Callable任务后，可以获取一个Future的对象，在该对象上调用get就可以获取到Callabl
阅读更多...
Callable及Future

Callable及Future

1.Runnable Runnable是个接口，使用很简单： 1. 实现该接口并重写run方法 2. 利用该类的对象创建线程 3. 线程启动时就会自动调用该对象的run方法 通常在开发中结合ExecutorService使用,将任务的提交与任务的执行解耦开,同时也能更好地利用Executor提供的各种特性 ExecutorService executor
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2