Java 并发编程之 FutureTask

FutureTask 类构造函数参数为 Callable 接口，实现 RunnableFuture 接口，而 RunnableFuture 接口继承了 Future 和 Runnable 接口，

所以它既是一个线程，也可以有返回结果。

使用栗子如下：

1）定义一个Callable 任务

public class CallableTask implements Callable<String> {private long sleepTime;public CallableTask(long sleepTime){this.sleepTime = sleepTime;}@Overridepublic String call() throws Exception {TimeUnit.SECONDS.sleep(sleepTime);return Thread.currentThread().getName();}}

2）定义线程池，执行 Callable 任务，使用 FutureTask 接收 Callable任务返回对象信息。

public class FutureTaskTest {public static void main(String[] args) {CallableTask callable1 = new CallableTask(3L);CallableTask callable2 = new CallableTask(5L);FutureTask<String> futureTask1 = new FutureTask<String>(callable1);FutureTask<String> futureTask2 = new FutureTask<String>(callable2);ExecutorService executor = Executors.newFixedThreadPool(2);executor.execute(futureTask1);executor.execute(futureTask2);while (true) {try {if (futureTask1.isDone() && futureTask2.isDone()){System.out.println("FutureTask1:" + futureTask1.get());System.out.println("FutureTask2:" + futureTask2.get());System.out.println("All FutureTasks are finished");executor.shutdown();return;}} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}}}
}

Java 并发编程之 FutureTask相关推荐

Java并发编程之FutureTask源码解析
上次总结一下AQS的一些相关知识,这次总结了一下FutureTask的东西,相对于AQS来说简单好多呀之前提到过一个LockSupport的工具类,也了解一下这个工具类的用法,这里也巩固一下吧 /* ...
zbb20180929 thread java并发编程之Condition
java并发编程之Condition 引言在java中,对于任意一个java对象,它都拥有一组定义在java.lang.Object上监视器方法,包括wait(),wait(long timeout ...
java并发编程之4——Java锁分解锁分段技术
转载自 java并发编程之4--Java锁分解锁分段技术并发编程的所有问题,最后都转换成了,"有状态bean"的状态的同步与互斥修改问题.而最后提出的解决"有状态bea ...
Java 并发编程之美：并发编程高级篇之一-chat
借用 Java 并发编程实践中的话:编写正确的程序并不容易,而编写正常的并发程序就更难了.相比于顺序执行的情况,多线程的线程安全问题是微妙而且出乎意料的,因为在没有进行适当同步的情况下多线程中各个操作 ...
Java 并发编程之美：并发编程高级篇之一
借用 Java 并发编程实践中的话:编写正确的程序并不容易,而编写正常的并发程序就更难了.相比于顺序执行的情况,多线程的线程安全问题是微妙而且出乎意料的,因为在没有进行适当同步的情况下多线程中各个操作 ...
Java并发编程之CAS第三篇-CAS的缺点
Java并发编程之CAS第三篇-CAS的缺点通过前两篇的文章介绍,我们知道了CAS是什么以及查看源码了解CAS原理.那么在多线程并发环境中,的缺点是什么呢?这篇文章我们就来讨论讨论本篇是<凯 ...
Java并发编程之CyclicBarrier详解
简介栅栏类似于闭锁,它能阻塞一组线程直到某个事件的发生.栅栏与闭锁的关键区别在于,所有的线程必须同时到达栅栏位置,才能继续执行.闭锁用于等待事件,而栅栏用于等待其他线程. CyclicBarrier ...
java并发编程之AbstractQueuedSynchronizer
引言 AbstractQueuedSynchronizer,队列同步器,简称AQS,它是java并发用来构建锁或者其他同步组件的基础框架. 一般使用AQS的主要方式是继承,子类通过实现它提供的抽象方法 ...
Java并发编程之synchronized关键字解析
前言公司加班太狠了,都没啥时间充电,这周终于结束了.这次整理了Java并发编程里面的synchronized关键字,又称为隐式锁,与JUC包中的Lock显示锁相对应:这个关键字从Java诞生开始就有 ...

Java 并发编程之 FutureTask

Java 并发编程之 FutureTask相关推荐

最新文章

热门文章