Java并发编程之Future和FutureTask

2024-02-28 08:32

本文主要是介绍Java并发编程之Future和FutureTask,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

搞过Java或者客户端Android开发的都知道,创建线程的2种方式,一种是直接继承Thread,另外一种就是实现Runnable接口。不过,这2种方式都有一个缺陷,就是在执行完任务之后无法获取执行结果。

如果需要获取执行结果,就必须通过共享变量或者使用线程通信的方式来达到效果,这就涉及到线程切换和线程通信等问题,就比较的麻烦。
不过,好在Java 从1.5版本开始,就提供了Callable和Future,通过它们可以在任务执行完毕之后得到任务执行结果。

Callable与Runnable
先看一下java.lang.Runnable,Runnable是一个接口,它里面只声明了一个run()方法。代码如下:

public interface Runnable {public abstract void run();
}

由于run()方法是一个void类型的,所以在执行完任务之后无法返回任何结果。

Callable位于java.util.concurrent包下,它也是一个接口,它里面也只声明了一个方法,只不过这个方法叫做call()。代码如下:

public interface Callable<V> {V call() throws Exception;
}

可以发现,Callable接受一个泛型,call()函数返回的类型就是传递进来的V类型。
那么怎么使用Callable呢?一般情况下Callable需要和ExecutorService配合使用,在ExecutorService接口中声明了若干个submit方法的重载版本。

<T> Future<T> submit(Callable<T> task);
<T> Future<T> submit(Runnable task, T result);
Future<?> submit(Runnable task);

其中,第一个submit方法里面的参数类型就是Callable。以下是一个完整的使用示例:

package thread.learn;import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;public class CallableAndFuture {static class MyThread implements Callable<String> {@Overridepublic String call() throws Exception {return "Hello world";}}static class MyThread2 implements Runnable {@Overridepublic void run() {}}public static void main(String[] args) {ExecutorService threadPool = Executors.newSingleThreadExecutor();Future<String> future = threadPool.submit(new MyThread());try {System.out.println(future.get());} catch (Exception e) {} finally {threadPool.shutdown();}}
}



Future
Future表示一个可能还没有完成的异步任务的结果,针对这个结果可以添加Callback以便在任务执行成功或失败后作出相应的操作。必要时可以通过get方法获取执行结果,该方法会阻塞直到任务返回结果。

Future类位于java.util.concurrent包下,它也是一个接口,定义如下:

public interface Future<V> {boolean cancel(boolean mayInterruptIfRunning);boolean isCancelled();boolean isDone();V get() throws InterruptedException, ExecutionException;V get(long timeout, TimeUnit unit)throws InterruptedException, ExecutionException, TimeoutException;
}



可以发现,Future接口中声明了5个方法,具体的含义如下:

cancel():cancel方法用来取消任务,如果取消任务成功则返回true,如果取消任务失败则返回false。参数mayInterruptIfRunning表示是否允许取消正在执行却没有执行完毕的任务,如果设置true,则表示可以取消正在执行过程中的任务。如果任务已经完成,则无论mayInterruptIfRunning为true还是false,此方法肯定返回false,即如果取消已经完成的任务会返回false;如果任务正在执行,若mayInterruptIfRunning设置为true,则返回true,若mayInterruptIfRunning设置为false,则返回false;如果任务还没有执行,则无论mayInterruptIfRunning为true还是false,肯定返回true。
isCancelled():isCancelled方法表示任务是否被取消成功,如果在任务正常完成前被取消成功,则返回 true。
isDone():isDone方法表示任务是否已经完成,若任务完成,则返回true。
get():get()方法用来获取执行结果,这个方法会产生阻塞,会一直等到任务执行完毕才返回。
get(long timeout, TimeUnit unit)用来获取执行结果,如果在指定时间内,还没获取到结果,就直接返回null。
综上可以发现,Future具有3种能力:
1 )判断任务是否完成;
2)能够中断任务;
3)能够获取任务执行结果。

同时,Future有4个子类,类图结构如下:

RunnableFuture
RunnableFuture接口同时继承Future接口和Runnable接口,并在成功执行run方法返回执行结果。这个接口的实现类有FutureTask,一个可取消的异步计算类。
FutureTask能用来包装一个Callable或Runnable对象,因为它实现了Runnable接口,而且它能被传递到Executor进行执行。为了提供单例类,这个类在创建自定义的工作类时提供了protected构造函数。

ScheduledFuture
ScheduledFuture接口表示一个延时的行为可以被取消,通常需要将一个安排好的Future配合定时任务SchedualedExecutorService执行,并返回执行的结果。

CompleteFuture
Complete表示操作已完成,所以CompleteFuture表示一个异步操作已完成的结果。当两个或多个线程要执行完成或取消操作时,只有一个能够成功。

ForkJoinPool
ForkJoinPool是一个基于任务的抽象类,可以通过ForkJoinPool来执行。一个ForkJoinTask是类似于线程实体,但是相对于线程实体是轻量级的。大量的任务和子任务会被ForkJoinPool池中的真实线程挂起来,以某些使用限制为代价。

FutureTask
先来看一下FutureTask的实现,源码如下:

public class FutureTask<V> implements RunnableFuture<V>

FutureTask类实现了RunnableFuture接口,再看一下RunnableFuture接口的实现。源码如下:

public interface RunnableFuture<V> extends Runnable, Future<V> {
    void run();
}

可以看出,RunnableFuture继承了Runnable接口和Future接口,而FutureTask实现了RunnableFuture接口。所以它既可以作为Runnable被线程执行,又可以作为Future得到Callable的返回值。

示例1
Callable+Future获取多线程的执行结果。

public class FutureDemo {public static void main(String[] args) {ExecutorService executor = Executors.newCachedThreadPool();Task task = new Task();Future<Integer> result = executor.submit(task);executor.shutdown();try {Thread.sleep(1000);} catch (InterruptedException e1) {e1.printStackTrace();}System.out.println("主线程在执行任务");try {System.out.println("task运行结果"+result.get());} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}System.out.println("所有任务执行完毕");}
}class Task implements Callable<Integer> {@Overridepublic Integer call() throws Exception {System.out.println("子线程在进行计算");Thread.sleep(3000);int sum = 0;for(int i=0;i<100;i++){sum += i;}return sum;}
}



执行结果:

子线程在进行计算
主线程在执行任务
task运行结果4950
所有任务执行完毕

示例2
使用Callable+FutureTask获取多线程的执行结果。

public class FutureTask {public static void main(String[] args) {//第一种方式ExecutorService executor = Executors.newCachedThreadPool();Task task = new Task();FutureTask<Integer> futureTask = new FutureTask<Integer>(task);executor.submit(futureTask);executor.shutdown();//第二种方式,注意这种方式和第一种方式效果是类似的,只不过一个使用的是ExecutorService,一个使用的是Thread/*Task task = new Task();FutureTask<Integer> futureTask = new FutureTask<Integer>(task);Thread thread = new Thread(futureTask);thread.start();*/try {Thread.sleep(1000);} catch (InterruptedException e1) {e1.printStackTrace();}System.out.println("主线程在执行任务");try {System.out.println("task运行结果"+futureTask.get());} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}System.out.println("所有任务执行完毕");}
}class Task implements Callable<Integer>{@Overridepublic Integer call() throws Exception {System.out.println("子线程在进行计算");Thread.sleep(3000);int sum = 0;for(int i=0;i<100;i++){sum += i;}return sum;}
}



示例3
例如,下面是一个典型的多线程场景:比如去吃早点时,点了包子和凉菜,包子需要等3分钟,凉菜只需1分钟,如果是串行的一个执行,在吃上早点的时候需要等待4分钟,但是因为你在等包子的时候,可以同时准备凉菜,所以在准备凉菜的过程中,可以同时准备包子,这样只需要等待3分钟。

public class FutureTaskDemo {public static void main(String[] args) throws ExecutionException, InterruptedException {long start = System.currentTimeMillis();// 等凉菜Callable ca1=new Callable() {@Overridepublic Object call() throws Exception {try {Thread.sleep(1000);}catch (Exception e){e.printStackTrace();}return "等凉菜";}};FutureTask<String> ft1 = new FutureTask<String>(ca1);new Thread(ft1).start();//等包子Callable ca2=new Callable() {@Overridepublic Object call() throws Exception {try {Thread.sleep(3000);}catch (Exception e){e.printStackTrace();}return "等包子";}};FutureTask<String> ft2 = new FutureTask<String>(ca2);new Thread(ft2).start();System.out.println(ft1.get());System.out.println(ft2.get());long end = System.currentTimeMillis();System.out.println(end-start);}
}


 

这篇关于Java并发编程之Future和FutureTask的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/754952

相关文章

如何在 Spring Boot 中实现 FreeMarker 模板

《如何在SpringBoot中实现FreeMarker模板》FreeMarker是一种功能强大、轻量级的模板引擎,用于在Java应用中生成动态文本输出(如HTML、XML、邮件内容等),本文... 目录什么是 FreeMarker 模板?在 Spring Boot 中实现 FreeMarker 模板1. 环

SpringMVC 通过ajax 前后端数据交互的实现方法

《SpringMVC通过ajax前后端数据交互的实现方法》:本文主要介绍SpringMVC通过ajax前后端数据交互的实现方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价... 在前端的开发过程中,经常在html页面通过AJAX进行前后端数据的交互,SpringMVC的controll

Java中的工具类命名方法

《Java中的工具类命名方法》:本文主要介绍Java中的工具类究竟如何命名,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录Java中的工具类究竟如何命名?先来几个例子几种命名方式的比较到底如何命名 ?总结Java中的工具类究竟如何命名?先来几个例子JD

Java Stream流使用案例深入详解

《JavaStream流使用案例深入详解》:本文主要介绍JavaStream流使用案例详解,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录前言1. Lambda1.1 语法1.2 没参数只有一条语句或者多条语句1.3 一个参数只有一条语句或者多

Spring Security自定义身份认证的实现方法

《SpringSecurity自定义身份认证的实现方法》:本文主要介绍SpringSecurity自定义身份认证的实现方法,下面对SpringSecurity的这三种自定义身份认证进行详细讲解,... 目录1.内存身份认证(1)创建配置类(2)验证内存身份认证2.JDBC身份认证(1)数据准备 (2)配置依

SpringBoot整合OpenFeign的完整指南

《SpringBoot整合OpenFeign的完整指南》OpenFeign是由Netflix开发的一个声明式Web服务客户端,它使得编写HTTP客户端变得更加简单,本文为大家介绍了SpringBoot... 目录什么是OpenFeign环境准备创建 Spring Boot 项目添加依赖启用 OpenFeig

Java Spring 中 @PostConstruct 注解使用原理及常见场景

《JavaSpring中@PostConstruct注解使用原理及常见场景》在JavaSpring中,@PostConstruct注解是一个非常实用的功能,它允许开发者在Spring容器完全初... 目录一、@PostConstruct 注解概述二、@PostConstruct 注解的基本使用2.1 基本代

springboot使用Scheduling实现动态增删启停定时任务教程

《springboot使用Scheduling实现动态增删启停定时任务教程》:本文主要介绍springboot使用Scheduling实现动态增删启停定时任务教程,具有很好的参考价值,希望对大家有... 目录1、配置定时任务需要的线程池2、创建ScheduledFuture的包装类3、注册定时任务,增加、删

SpringBoot整合mybatisPlus实现批量插入并获取ID详解

《SpringBoot整合mybatisPlus实现批量插入并获取ID详解》这篇文章主要为大家详细介绍了SpringBoot如何整合mybatisPlus实现批量插入并获取ID,文中的示例代码讲解详细... 目录【1】saveBATch(一万条数据总耗时:2478ms)【2】集合方式foreach(一万条数

IntelliJ IDEA 中配置 Spring MVC 环境的详细步骤及问题解决

《IntelliJIDEA中配置SpringMVC环境的详细步骤及问题解决》:本文主要介绍IntelliJIDEA中配置SpringMVC环境的详细步骤及问题解决,本文分步骤结合实例给大... 目录步骤 1:创建 Maven Web 项目步骤 2:添加 Spring MVC 依赖1、保存后执行2、将新的依赖