首页 > 其他分享 >Future和Callable

Future和Callable

时间：2024-03-02 13:55:18浏览次数：17  
标签：get Callable 任务 Future catch new public

Future和Callable

Runnable缺陷

  • 不能返回一个返回值
  • 也不能抛出checked Exception

Callable接口

  • 类似于Runnable,被其它线程执行的任务
  • 实现call方法
  • 有返回值

Future

  • 可以用Future.get来获取Callable接口返回的执行结果，还可以通过Future.isDone()来判断任务是否已经执行完了，以及取消这个任务，限时获取任务的结果等
  • 在call()未执行完毕之前，调用get()的线程(假定此时是主线程)会被阻塞，直到call()方法返回了结果后，此时future.get()才会得到该结果，然后主线程才会切换到runnable状态
  • 所以Future是一个存储器，它存储了call()这个任务的结果，而这个任务的执行时间是无法提前确定的，因为这完全取决于call()方法执行的情况

get():获取结果

get方法的行为取决于Callable任务的状态，只有以下这5种情况：

1.任务正常完成：get方法会立刻返回结果

2.任务尚未完成(任务还没开始或进行中):get将阻塞并直到任务完成

3.任务执行过程中get方法会抛出ExecutionException这里的抛出异常，是call(执行时产生的那个异常，看到这个异常类型是java.util.concurrent.ExecutionException。不论call()执行时抛出的异常类型是什么,最后get方法抛出的异常类型都是ExecutionException。

4.任务被取消：get方法会抛出CancellationException

5.任务超时：get方法有一个重载方法，是传入一个延迟时间的如果时间到了还没有获得结果，get方法就会抛出TimeoutException。

用get(long timeout,TimeUnit unit)方法时，如果call()在规定时间内完成了任务，那么就会正常获取到返回值；而如果再指定时间内没有计算出结果，那么就会抛出TimeoutException

cancel（）方法：取消任务

isDone()方法：判断线程是否执行完毕

isCanncelled()方法：判断是否被取消

线程池的submit方法返回Future对象

首先，我们要给线程池提交我们的任务，提交时线程池会立刻返回给我们一个空的Future容器。当线程的任务一旦执行完毕也就是当我们可以获取结果的时候，线程池便会把该结果填入到之前给我们的那个Future中去(而不是创建-个新的Future),我们此时便可以从该Future中获得任务执行的结果

public class OneFuture {

public static void main(String[] args) {
ExecutorService service = Executors.newFixedThreadPool(10);
Future<Integer> future = service.submit(new CallableTask());
try {
System.out.println(future.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
service.shutdown();
}

static class CallableTask implements Callable<Integer> {

@Override
public Integer call() throws Exception {
Thread.sleep(3000);
return new Random().nextInt();
}
}

}

Futrue的Lambda

public class OneFutureLambda {

public static void main(String[] args) {
ExecutorService service = Executors.newFixedThreadPool(10);
Callable<Integer> callable = () -> {
Thread.sleep(3000);
return new Random().nextInt();
};
Future<Integer> future = service.submit(callable);
try {
System.out.println(future.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
service.shutdown();
}

}

批量接收结果

多个任务，用Futrue数组来获取结果

public class MultiFutures {

public static void main(String[] args) throws InterruptedException {
ExecutorService service = Executors.newFixedThreadPool(20);
ArrayList<Future> futures = new ArrayList<>();
for (int i = 0; i < 20; i++) {
Future<Integer> future = service.submit(new CallableTask());
futures.add(future);
}
Thread.sleep(5000);
for (int i = 0; i < 20; i++) {
Future<Integer> future = futures.get(i);
try {
Integer integer = future.get();
System.out.println(integer);
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
}

static class CallableTask implements Callable<Integer> {

@Override
public Integer call() throws Exception {
Thread.sleep(3000);
return new Random().nextInt();
}
}
}

执行时异常和isDone()

/**
* 描述： 演示get方法过程中抛出异常，for循环为了演示抛出Exception的时机：并不是说一产生异常就抛出，直到我们get执行时，才会抛出。
*/
public class GetException {

public static void main(String[] args) {
ExecutorService service = Executors.newFixedThreadPool(20);
Future<Integer> future = service.submit(new CallableTask());


try {
for (int i = 0; i < 5; i++) {
System.out.println(i);
Thread.sleep(500);
}
System.out.println(future.isDone());
future.get();
} catch (InterruptedException e) {
e.printStackTrace();
System.out.println("InterruptedException异常");
} catch (ExecutionException e) {
e.printStackTrace();
System.out.println("ExecutionException异常");
}
}


static class CallableTask implements Callable<Integer> {

@Override
public Integer call() throws Exception {
throw new IllegalArgumentException("Callable抛出异常");
}
}
}

获取任务超时

/**
* 描述： 演示get的超时方法，需要注意超时后处理，调用future.cancel()。演示cancel传入true和false的区别，代表是否中断正在执行的任务。
*/
public class Timeout {

private static final Ad DEFAULT_AD = new Ad("无网络时候的默认广告");
private static final ExecutorService exec = Executors.newFixedThreadPool(10);

static class Ad {

String name;

public Ad(String name) {
this.name = name;
}

@Override
public String toString() {
return "Ad{" +
"name='" + name + '\'' +
'}';
}
}


static class FetchAdTask implements Callable<Ad> {

@Override
public Ad call() throws Exception {
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
System.out.println("sleep期间被中断了");
return new Ad("被中断时候的默认广告");
}
return new Ad("旅游订票哪家强？找某程");
}
}


public void printAd() {
Future<Ad> f = exec.submit(new FetchAdTask());
Ad ad;
try {
ad = f.get(2000, TimeUnit.MILLISECONDS);
} catch (InterruptedException e) {
ad = new Ad("被中断时候的默认广告");
} catch (ExecutionException e) {
ad = new Ad("异常时候的默认广告");
} catch (TimeoutException e) {
ad = new Ad("超时时候的默认广告");
System.out.println("超时，未获取到广告");
boolean cancel = f.cancel(true);
System.out.println("cancel的结果：" + cancel);
}
exec.shutdown();
System.out.println(ad);
}

public static void main(String[] args) {
Timeout timeout = new Timeout();
timeout.printAd();
}
}

取消任务cancel

1.如果这个任务还没有开始执行，那么这种情兄最简單，任务会被正常的取消，未来也不会被执行，方法返回true。

2.如果任务已完成，或者已取消：那么cancel()方法会执行失败方法返回false。

3.如果这个任务已经开始执行了，那么这个取消方法将不会直接取消该任务，而是会根据我们填的参数mayInterruptIfRunning做判断

Future.cancel(true)适用于：

1.任务能够处理interrupt

Future.cancel(false)仅用于避免启动尚未启动的任务，适用于：

1.未能处理interrupt的任务

2.不清楚任务是否支持取消

3.需要等待已经开始的任务执行完成

FutureTask来获取Future和任务结果

  • FutureTask是一种包装器，可以把Callable转化成Future和Runnable,它同时实现二者的接口

  • 把Callable实例当作参数，生成FutureTask的对象，然后把这个对象当作一个Runnable对象，用线程池或另起线程去执行这个Runnable对象，最后通过FutureTask获取刚才执行的结果

/**
* 描述： 演示FutureTask的用法
*/
public class FutureTaskDemo {

public static void main(String[] args) {
Task task = new Task();
FutureTask<Integer> integerFutureTask = new FutureTask<>(task);
// new Thread(integerFutureTask).start();
ExecutorService service = Executors.newCachedThreadPool();
service.submit(integerFutureTask);

try {
System.out.println("task运行结果："+integerFutureTask.get());

} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
}

class Task implements Callable<Integer> {

@Override
public Integer call() throws Exception {
System.out.println("子线程正在计算");
Thread.sleep(3000);
int sum = 0;
for (int i = 0; i < 100; i++) {
sum += i;
}
return sum;
}
}

Future注意点

  • 当for循环批量获取future的结果时，容易发生一部分线程很慢的情况，get方法调用时应使用timeout限制
  • Future的生命周期不能后退

标签：get,Callable,任务,Future,catch,new,public
From： https://www.cnblogs.com/wangzhilei-src/p/18048575

相关文章

  • JUC系列之（六）实现Callable接口
    实现Callable接口创建执行线程的第三种方式，共四种比较Runnable和Callable：Callable方法可以有返回值,并且可以抛出异常。由于Callable的方法有返回值，需要FutureTask的支持，用于接收运算结果。FutureTask是Future接口的实现类。使用packagecom.atguigu.juc;importjava.......
  • JAVA之CompletableFuture
    目录CompletableFuture入门学习内容学习目标课程学习说明1、FuturevsCompletableFuture1.1准备工作1.2Future的局限性1.3CompletableFuture的优势2、创建异步任务2.1runAsync2.2supplyAsync2.3异步任务中的线程池2.4异步编程思想3、异步任务回调3.1thenApply3.2thenA......
  • 【内容管理及平台建设】上海道宁为您提供全媒体信息管理平台——WebFuture
     在数字化、智能化的浪潮下我们的生活和工作方式正在经历前所未有的变革  动易软件是综合性软件平台更是一种全新的生活和工作方式为客户提供互联网内容管理移动互联网内容管理全媒体内容管理的平台建设及技术服务  PART01：开发商......
  • QOJ7899 Say Hello to the future
    QOJ7899SayHellotothefuture考虑先不管修改怎么做。考虑DP，\(f_i\)表示前缀的答案，然后cdq分治优化转移。考虑\(a_i\)最大值所在位置，若在右侧那么\(f_i\)可以被左侧的一个区间转移到，否则左侧的\(f_j\)可以转移到右侧的一个区间，两者都可以线性做。然后考虑问询。我们......
  • CompletableFuture异步编程详解
    Future介绍先来回顾下Future，Future是JDK1.5中添加的接口，主要功能为：获取并发的任务完成后的执行结果；能够取消并发执行中的任务；判断并发任务是否执行完成；但Future也有着非常明显的缺点：阻塞：调用get()方法会一直阻塞，直到等待直到计算完成；异常处理：Future没有提供任何异常处理的方......
  • 玩转CompletableFuture线程异步编排，看这一篇就够了
    转载自：https://blog.csdn.net/w306026355/article/details/1097072691、CompletableFuture介绍CompletableFuture可用于线程异步编排，使原本串行执行的代码，变为并行执行，提高代码执行速度。学习异步编排先需要学习线程池和lambda表达式相关知识，学习线程池可以移步我的另一篇博......
  • flutter开发Future与Stream的理解和区别
    flutter开发Future与Stream的理解和区别Future特点Future是表示一个异步操作的单个结果，只返回一次结果。通常用于处理一次性的异步操作。Future通过then()和catchError()方法来处理异步操作的结果和异常。Future使用await关键字来等待异步操作完成。FutureBuilder：通过监听......
  • Java并发编程-CompletableFuture（上）
    大家好，我是小高先生，这篇文章我将和大家一起学习Java并发编程中很重要的一个类-CompletableFuture。 在Java的并发编程领域，Future接口一直扮演着关键的角色，它定义了一组与异步任务执行相关的方法，包括获取异步任务的结果、取消任务执行以及检查任务是否已完成等。然而，随着业务场......
  • Java并发编程-CompletableFuture（下）
    大家好，我是小高先生，书接上文，我们继续来学习CompletableFuture。上文我们讲了基础装Future是如何升级为神装CompletableFuture以及如何购买CompletableFuture，接下来我们一起来学习如何在战斗中使用CompletableFuture。CompletableFuture的基本使用CompletableFuture的实战案例C......
  • Future和FutureTask
    (Future和FutureTask)Future类FutureTask叫未来任务，可以将一个复杂的任务剔除出去交给另外一个线程来完成Future主要方法get()get方法的行为取决于Callable任务的状态，只有以下5种情况:任务正常完成:get方法会立刻返回结果任务尚未完成:任务还没有开始或进行中，get将阻塞并......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99