Java线程之FutureTask

标签： java 线程 futuretask | 发表时间：2015-05-04 17:33 | 作者：
出处：http://m635674608.iteye.com

FutureTask是Future和Callable的结合体。传统的代码是这样写的

Future f = executor.submit(new Callable());

然后通过Future来取得计算结果。但是，若开启了多个任务，我们无从知晓哪个任务最先结束，因此，若要实现“当某任务结束时，立刻做一些事情，例如记录日志”这一功能，就需要写一些额外的代码。

FutureTask正是为此而存在，他有一个回调函数protected void done()，当任务结束时，该回调函数会被触发。因此，只需重载该函数，即可实现在线程刚结束时就做一些事情。

[java] view plain copy
  1. public class Test {  
  2.     public static void main(String[] args) {  
  3.         ExecutorService executor = Executors.newCachedThreadPool();  
  4.         for(int i=0; i<5; i++) {  
  5.             Callable<String> c = new Task();  
  6.             MyFutureTask ft = new MyFutureTask(c);  
  7.             executor.submit(ft);  
  8.         }  
  9.         executor.shutdown();  
  10.     }  
  11.           
  12. }  
  13.   
  14. class MyFutureTask extends FutureTask<String> {  
  15.   
  16.     public MyFutureTask(Callable<String> callable) {  
  17.         super(callable);  
  18.     }  
  19.   
  20.     @Override  
  21.     protected void done() {  
  22.         try {  
  23.             System.out.println(get() + " 线程执行完毕！~");  
  24.         } catch (InterruptedException | ExecutionException e) {  
  25.             // TODO Auto-generated catch block  
  26.             e.printStackTrace();  
  27.         }  
  28.     }  
  29.       
  30.       
  31. }  
  32.   
  33. class Task implements Callable<String> {  
  34.   
  35.     @Override  
  36.     public String call() throws Exception {  
  37.         Random rand = new Random();  
  38.         TimeUnit.SECONDS.sleep(rand.nextInt(12));  
  39.         return Thread.currentThread().getName();  
  40.     }  
  41. } 


已有 0 人发表留言，猛击->> 这里<<-参与讨论


ITeye推荐



相关 [java 线程 futuretask] 推荐：

Java线程之FutureTask

- - zzm
FutureTask是Future和Callable的结合体. 然后通过Future来取得计算结果. 但是，若开启了多个任务，我们无从知晓哪个任务最先结束，因此，若要实现“当某任务结束时，立刻做一些事情，例如记录日志”这一功能，就需要写一些额外的代码. FutureTask正是为此而存在，他有一个回调函数protected void done()，当任务结束时，该回调函数会被触发.

Java中的Runnable、Callable、Future、FutureTask的区别

- - IT瘾-geek
Java中存在Runnable、Callable、Future、FutureTask这几个与线程相关的类或者接口，在Java中也是比较重要的几个概念，我们通过下面的简单示例来了解一下它们的作用于区别. 其中Runnable应该是我们最熟悉的接口，它只有一个run()函数，用于将耗时操作写在其中， 该函数没有返回值.

Future 与 FutureTask

- - 码蜂笔记
来自 Java DOC 文档：Future 表示异步计算的结果. 它提供了检查计算是否完成的方法，以等待计算的完成，并获取计算的结果. 计算完成后只能使用 get 方法来获取结果，如有必要，计算完成前可以阻塞此方法. 取消则由 cancel 方法来执行. 还提供了其他方法，以确定任务是正常完成还是被取消了.

Java线程池

- - 企业架构 - ITeye博客
线程的使用在java中占有极其重要的地位，在jdk1.4极其之前的jdk版本中，关于线程池的使用是极其简陋的. 在jdk1.5之后这一情况有了很大的改观. Jdk1.5之后加入了java.util.concurrent包，这个包中主要介绍java中线程以及线程池的使用. 为我们在开发中处理线程的问题提供了非常大的帮助.

Java 线程池

- - 编程语言 - ITeye博客
在项目中，系统启动一个新线程的成本是比较高的，因为它涉及与操作系统交互. 在这种情形下，使用线程池可以很好地提高性能，尤其是当程序中需要创建大量生存周期很短的线程时，更应该考虑使用线程池. 使用线程池可以有效地控制系统中并发线程的数量，当系统中包含大量并发线程时，会导致系统性能剧烈下降，甚至导致JVM崩溃，而线程池的最大线程数参数可以控制系统中并发线程数不超过此数.

Java Thread多线程

- - CSDN博客推荐文章
Java Thread多线程. Java 多线程例子1 小例子. super("zhuyong");//设置线程的名字，默认为“TestThread”. Java 多线程例子2 前台线程（用户线程） 后台线程（守护线程 ）. 1，setDaemon（true）后就是后台线程（守护线程 ），反之就是前台线程（用户线程）.

[Java] Java 多线程案例分析

- - V2EX
现要从 hbase中导出 2016 年整年的，大约 10w只股票行情数据，数据总量约 100t. 汇总到 hdfs中供需求方使用. 已知数据量规模大概是 100t，那么单台机器处理肯定不是不行的，先不说大多数磁盘都没这么大，即便磁盘有这么大，单台机器处理对于内存和 cpu 要求也很高，所以我们将问题一般化，使用数量有限的低配机器.

Java多线程之synchronized

- - CSDN博客推荐文章
这里通过三个测试类阐述了synchronized应用的不同场景. 首先是最基本的synchronized Method的使用.  * @see 概述：Java中的每个对象都有一个锁(lock)或者叫做监视器(monitor) .  * @see 说明：当synchronized关键字修饰一个方法时，则该方法为同步方法 .

java线程池分析

- - BlogJava-首页技术区
    在Java 5.0之前启动一个任务是通过调用Thread类的start()方法来实现的，任务的提于交和执行是同时进行的，如果你想对任务的执行进行调度或是控制 同时执行的线程数量就需要额外编写代码来完成. 5.0里提供了一个新的任务执行架构使你可以轻松地调度和控制任务的执行，并且可以建立一个类似数据库连接 池的线程池来执行任务.

java线程取消方式

- - 编程语言 - ITeye博客
JAVA任务取消方式一般有2种. 第一种设置某个取消标志，任务定期查看该标志，这种方式存在任务取消并不能保证任务立即取消，更糟糕的是有可能任务永远不会结束. 第二种是利用的中断机制，JVM并不能保证阻塞方法检测到中断的速度，但是实际中还是非常快的. 实例一（使用取消标志，会发现取消的任务还执行中，只有执行完再次检测标志任务才取消）.