【转】浅谈futureTask_JAVA_编程开发_程序员俱乐部

API： Java代码??

1. public?interface?Executor?{??????
2. ????void?execute(Runnable?command);????
3. }???
4. ??
5. public?interface?ExecutorService?extends?Executor?{????
6. ????
7. ????<T>?Future<T>?submit(Callable<T>?task);?????????
8. ????<T>?Future<T>?submit(Runnable?task,?T?result);??????
9. ????Future<?>?submit(Runnable?task);??????????
10. ????...???????
11. }????
12. ??
13. public?class?FutureTask<V>??extends?Object????
14. ????????????implements?Future<V>,?Runnable???
15. FutureTask(Callable<V>?callable)?????
16. ??????//创建一个?FutureTask，一旦运行就执行给定的?Callable。??????
17. FutureTask(Runnable?runnable,?V?result)?????
18. ??????//创建一个?FutureTask，一旦运行就执行给定的?Runnable，并安排成功完成时?get?返回给定的结果?。????
19. ??
20. /*参数：???
21. runnable?-?可运行的任务。???
22. result?-?成功完成时要返回的结果。???
23. 如果不需要特定的结果，则考虑使用下列形式的构造：Future<?>?f?=?new?FutureTask<Object>(runnable,?null)??*/??

?FutureTask多用于耗时的计算，主线程可以在完成自己的任务后，再去获取结果。

?

单独使用Runnable时：

? ? ? ? 无法获得返回值

?

单独使用Callable时：

? ? ? ? 无法在新线程中(new Thread(Runnable r))使用，只能使用ExecutorService

? ? ? ??Thread类只支持Runnable

?

FutureTask：

? ? ? ? ?实现了Runnable和Future，所以兼顾两者优点

? ? ? ? ?既可以使用ExecutorService，也可以使用Thread

?

Java代码??

1. Callable?pAccount?=?new?PrivateAccount();????
2. ????FutureTask?futureTask?=?new?FutureTask(pAccount);????
3. ????//?使用futureTask创建一个线程????
4. ????Thread?thread?=?new?Thread(futureTask);????
5. ????thread.start();????

?

?

=================================================================

public interface Future<V> Future 表示异步计算的结果。
Future有个get方法而获取结果只有在计算完成时获取，否则会一直阻塞直到任务转入完成状态，然后会返回结果或者抛出异常。?

?

FutureTask是为了弥补Thread的不足而设计的，它可以让程序员准确地知道线程什么时候执行完成并获得到线程执行完成后返回的结果（如果有需要）。

?

FutureTask是一种可以取消的异步的计算任务。它的计算是通过Callable实现的，它等价于可以携带结果的Runnable，并且有三个状态：等待、运行和完成。完成包括所有计算以任意的方式结束，包括正常结束、取消和异常。

?

Future 主要定义了5个方法：?

1)boolean?cancel(boolean mayInterruptIfRunning)：试图取消对此任务的执行。如果任务已完成、或已取消，或者由于某些其他原因而无法取消，则此尝试将失败。当调用 cancel 时，如果调用成功，而此任务尚未启动，则此任务将永不运行。如果任务已经启动，则 mayInterruptIfRunning 参数确定是否应该以试图停止任务的方式来中断执行此任务的线程。此方法返回后，对 isDone() 的后续调用将始终返回 true。如果此方法返回 true，则对 isCancelled() 的后续调用将始终返回 true。?

2）boolean?isCancelled()：如果在任务正常完成前将其取消，则返回 true。?
3）boolean?isDone()：如果任务已完成，则返回 true。 可能由于正常终止、异常或取消而完成，在所有这些情况中，此方法都将返回 true。?
4）V?get()throws InterruptedException,ExecutionException：如有必要，等待计算完成，然后获取其结果。?
5）V?get(long timeout,TimeUnit unit) throws InterruptedException,ExecutionException,TimeoutException：如有必要，最多等待为使计算完成所给定的时间之后，获取其结果（如果结果可用）。

?

Java代码??

1. public?class?FutureTask<V>??extends?Object??
2. ????implements?Future<V>,?Runnable??

?FutureTask类是Future 的一个实现，并实现了Runnable，所以可通过Excutor(线程池) 来执行,也可传递给Thread对象执行。如果在主线程中需要执行比较耗时的操作时，但又不想阻塞主线程时，可以把这些作业交给Future对象在后台完成，当主线程将来需要时，就可以通过Future对象获得后台作业的计算结果或者执行状态。?

Executor框架利用FutureTask来完成异步任务，并可以用来进行任何潜在的耗时的计算。一般FutureTask多用于耗时的计算，主线程可以在完成自己的任务后，再去获取结果。

?

JDK:

此类提供了对 Future 的基本实现。仅在计算完成时才能检索结果；如果计算尚未完成，则阻塞 get 方法。一旦计算完成，就不能再重新开始或取消计算。

?

可使用 FutureTask 包装 Callable 或 Runnable 对象。因为 FutureTask 实现了 Runnable，所以可将 FutureTask 提交给 Executor 执行。

?

?

Java代码??

1. 构造方法摘要??
2. FutureTask(Callable<V>?callable)???
3. ??????????创建一个?FutureTask，一旦运行就执行给定的?Callable。??
4. ??
5. FutureTask(Runnable?runnable,?V?result)???
6. ??????????创建一个?FutureTask，一旦运行就执行给定的?Runnable，并安排成功完成时?get?返回给定的结果?。??
7. 参数：??
8. runnable?-?可运行的任务。??
9. result?-?成功完成时要返回的结果。??
10. 如果不需要特定的结果，则考虑使用下列形式的构造：Future<?>?f?=?new?FutureTask<Object>(runnable,?null)??

?

Example1:

下面的例子模拟一个会计算账的过程，主线程已经获得其他帐户的总额了，为了不让主线程等待 PrivateAccount类的计算结果的返回而启用新的线程去处理， 并使用 FutureTask对象来监控，这样，主线程还可以继续做其他事情， 最后需要计算总额的时候再尝试去获得privateAccount 的信息。?

?

Java代码??

1. package?test;??
2. ??
3. import?java.util.Random;??
4. import?java.util.concurrent.Callable;??
5. import?java.util.concurrent.ExecutionException;??
6. import?java.util.concurrent.FutureTask;??
7. ??
8. /**?
9. ?*?
10. ?*?@author?Administrator?
11. ?*?
12. ?*/??
13. @SuppressWarnings("all")??
14. public?class?FutureTaskDemo?{??
15. ????public?static?void?main(String[]?args)?{??
16. ????????//?初始化一个Callable对象和FutureTask对象??
17. ????????Callable?pAccount?=?new?PrivateAccount();??
18. ????????FutureTask?futureTask?=?new?FutureTask(pAccount);??
19. ????????//?使用futureTask创建一个线程??
20. ????????Thread?pAccountThread?=?new?Thread(futureTask);??
21. ????????System.out.println("futureTask线程现在开始启动，启动时间为："?+?System.nanoTime());??
22. ????????pAccountThread.start();??
23. ????????System.out.println("主线程开始执行其他任务");??
24. ????????//?从其他账户获取总金额??
25. ????????int?totalMoney?=?new?Random().nextInt(100000);??
26. ????????System.out.println("现在你在其他账户中的总金额为"?+?totalMoney);??
27. ????????System.out.println("等待私有账户总金额统计完毕...");??
28. ????????//?测试后台的计算线程是否完成，如果未完成则等待??
29. ????????while?(!futureTask.isDone())?{??
30. ????????????try?{??
31. ????????????????Thread.sleep(500);??
32. ????????????????System.out.println("私有账户计算未完成继续等待...");??
33. ????????????}?catch?(InterruptedException?e)?{??
34. ????????????????e.printStackTrace();??
35. ????????????}??
36. ????????}??
37. ????????System.out.println("futureTask线程计算完毕，此时时间为"?+?System.nanoTime());??
38. ????????Integer?privateAccountMoney?=?null;??
39. ????????try?{??
40. ????????????privateAccountMoney?=?(Integer)?futureTask.get();??
41. ????????}?catch?(InterruptedException?e)?{??
42. ????????????e.printStackTrace();??
43. ????????}?catch?(ExecutionException?e)?{??
44. ????????????e.printStackTrace();??
45. ????????}??
46. ????????System.out.println("您现在的总金额为："?+?totalMoney?+?privateAccountMoney.intValue());??
47. ????}??
48. }??
49. ??
50. @SuppressWarnings("all")??
51. class?PrivateAccount?implements?Callable?{??
52. ????Integer?totalMoney;??
53. ??
54. ????@Override??
55. ????public?Object?call()?throws?Exception?{??
56. ????????Thread.sleep(5000);??
57. ????????totalMoney?=?new?Integer(new?Random().nextInt(10000));??
58. ????????System.out.println("您当前有"?+?totalMoney?+?"在您的私有账户中");??
59. ????????return?totalMoney;??
60. ????}??
61. ??
62. }??

?运行结果???

?

来源：

http://zheng12tian.iteye.com/blog/991484

?

Example2： Java代码??

1. public?class?FutureTaskSample?{??
2. ??????
3. ????static?FutureTask<String>?future?=?new?FutureTask(new?Callable<String>(){??
4. ????????public?String?call(){??
5. ????????????return?getPageContent();??
6. ????????}??
7. ????});??
8. ??????
9. ????public?static?void?main(String[]?args)?throws?InterruptedException,?ExecutionException{??
10. ????????//Start?a?thread?to?let?this?thread?to?do?the?time?exhausting?thing??
11. ????????new?Thread(future).start();??
12. ??
13. ????????//Main?thread?can?do?own?required?thing?first??
14. ????????doOwnThing();??
15. ??
16. ????????//At?the?needed?time,?main?thread?can?get?the?result??
17. ????????System.out.println(future.get());??
18. ????}??
19. ??????
20. ????public?static?String?doOwnThing(){??
21. ????????return?"Do?Own?Thing";??
22. ????}??
23. ????public?static?String?getPageContent(){??
24. ????????return?"Callable?method...";??
25. ????}??
26. }??

?结果为：Callable method...
不科学啊，为毛？？！（金鱼：蹦蛋，没有打印当然出不来=_=） 来源：http://tomyz0223.iteye.com/blog/1019924 ?改为这样，结果就正常： Java代码??

1. public?class?FutureTaskSample?{????
2. ????????
3. ????public?static?void?main(String[]?args)?throws?InterruptedException,?ExecutionException{????
4. ????????//Start?a?thread?to?let?this?thread?to?do?the?time?exhausting?thing????
5. ????????Callable?call?=?new?MyCallable();??
6. ????????FutureTask?future?=?new?FutureTask(call);??
7. ????????new?Thread(future).start();????
8. ????
9. ????????//Main?thread?can?do?own?required?thing?first????
10. ????????//doOwnThing();????
11. ????????System.out.println("Do?Own?Thing");????
12. ??????????
13. ????????//At?the?needed?time,?main?thread?can?get?the?result????
14. ????????System.out.println(future.get());????
15. ????}????
16. ??????
17. }????
18. ??
19. ??
20. ????class?MyCallable?implements?Callable<String>{??
21. ??
22. ????????@Override??
23. ????????public?String?call()?throws?Exception?{??
24. ?????????????return?getPageContent();????
25. ????????}??
26. ??????????
27. ????????public?String?getPageContent(){????
28. ????????????return?"Callable?method...";????
29. ????????}???
30. ????}??

?结果： Do Own Thing Callable method...

?

?Example3：
Java代码??

1. import?java.util.concurrent.Callable;??
2. ??
3. public?class?Changgong?implements?Callable<Integer>{??
4. ??
5. ????private?int?hours=12;??
6. ????private?int?amount;??
7. ??????
8. ????@Override??
9. ????public?Integer?call()?throws?Exception?{??
10. ????????while(hours>0){??
11. ????????????System.out.println("I'm?working......");??
12. ????????????amount?++;??
13. ????????????hours--;??
14. ????????????Thread.sleep(1000);??
15. ????????}??
16. ????????return?amount;??
17. ????}??
18. }??

? Java代码??

1. public?class?Dizhu?{??
2. ??????????
3. ????public?static?void?main(String?args[]){??
4. ????????Changgong?worker?=?new?Changgong();??
5. ????????FutureTask<Integer>?jiangong?=?new?FutureTask<Integer>(worker);??
6. ????????new?Thread(jiangong).start();??
7. ????????while(!jiangong.isDone()){??
8. ????????????try?{??
9. ????????????????System.out.println("看长工做完了没...");??
10. ????????????????Thread.sleep(1000);??
11. ????????????}?catch?(InterruptedException?e)?{??
12. ????????????????//?TODO?Auto-generated?catch?block??
13. ????????????????e.printStackTrace();??
14. ????????????}??
15. ????????}??
16. ????????int?amount;??
17. ????????try?{??
18. ????????????amount?=?jiangong.get();??
19. ????????????System.out.println("工作做完了,上交了"+amount);??
20. ????????}?catch?(InterruptedException?e)?{??
21. ????????????//?TODO?Auto-generated?catch?block??
22. ????????????e.printStackTrace();??
23. ????????}?catch?(ExecutionException?e)?{??
24. ????????????//?TODO?Auto-generated?catch?block??
25. ????????????e.printStackTrace();??
26. ????????}??
27. ????}??
28. }??

?
结果： 看工人做完了没...
I'm?working......
看工人做完了没...
I'm?working......
看工人做完了没...
I'm?working......
看工人做完了没...
I'm?working......
看工人做完了没...
I'm?working......
看工人做完了没...
I'm?working......
看工人做完了没...
I'm?working......
看工人做完了没...
I'm?working......
看工人做完了没...
I'm?working......
看工人做完了没...
I'm?working......
看工人做完了没...
I'm?working......
看工人做完了没...
I'm?working......
看工人做完了没...
工作做完了,上交了