Java线程池在运行后的结果反查

Java线程池需要不断的学习，在学习的时候我们就要注意不少的问题。下面我们就来看看具体的语言运作环境如何才能满足Java线程池相关程序的运行。希望大家有所收获。

泽库网站制作公司哪家好，找创新互联！从网页设计、网站建设、微信开发、APP开发、响应式网站设计等网站项目制作，到程序开发，运营维护。创新互联2013年开创至今到现在10年的时间，我们拥有了丰富的建站经验和运维经验，来保证我们的工作的顺利进行。专注于网站建设就选创新互联。

无论是接收Runnable型参数，还是接收Callable型参数的submit()方法，都会返回一个Future（也是一个接口）类型的对象。该对象中包含了任务的执行情况以及结果。调用Future的boolean isDone()方法可以获知任务是否执行完毕；调用Object get()方法可以获得任务执行后的返回结果，如果此时任务还没有执行完，get()方法会保持等待，直到相应的任务执行完毕后，才会将结果返回。

我们用下面的一个例子来演示Java5.0中Java线程池的使用：

Java代码

 
 
 
    
  
  
  
  1. import java.util.concurrent.*;  
    2. 
  
  
  
  2. public class ExecutorTest {  
    3. 
  
  
  
  3. public static void main(String[] args) throws 
    InterruptedException,  
    4. 
  
  
  
  4. ExecutionException {  
    5. 
  
  
  
  5. ExecutorService es = Executors.newSingleThreadExecutor();  
    6. 
  
  
  
  6. Future fr = es.submit(new RunnableTest());// 提交任务  
    7. 
  
  
  
  7. Future fc = es.submit(new CallableTest());// 提交任务  
    8. 
  
  
  
  8. // 取得返回值并输出  
    9. 
  
  
  
  9. System.out.println((String) fc.get());  
    10. 
  
  
  
  10. // 检查任务是否执行完毕  
    11. 
  
  
  
  11. if (fr.isDone()) {  
    12. 
  
  
  
  12. System.out.println("执行完毕-RunnableTest.run()");  
    13. 
  
  
  
  13. } else {  
    14. 
  
  
  
  14. System.out.println("未执行完-RunnableTest.run()");  
    15. 
  
  
  
  15. }  
    16. 
  
  
  
  16. // 检查任务是否执行完毕  
    17. 
  
  
  
  17. if (fc.isDone()) {  
    18. 
  
  
  
  18. System.out.println("执行完毕-CallableTest.run()");  
    19. 
  
  
  
  19. } else {  
    20. 
  
  
  
  20. System.out.println("未执行完-CallableTest.run()");  
    21. 
  
  
  
  21. }  
    22. 
  
  
  
  22. // 停止线程池服务  
    23. 
  
  
  
  23. es.shutdown();  
    24. 
  
  
  
  24. }  
    25. 
  
  
  
  25. }  
    26. 
  
  
  
  26. class RunnableTest implements Runnable {  
    27. 
  
  
  
  27. public void run() {  
    28. 
  
  
  
  28. System.out.println("已经执行-RunnableTest.run()");  
    29. 
  
  
  
  29. }  
    30. 
  
  
  
  30. }  
    31. 
  
  
  
  31. class CallableTest implements Callable {  
    32. 
  
  
  
  32. public Object call() {  
    33. 
  
  
  
  33. System.out.println("已经执行-CallableTest.call()");  
    34. 
  
  
  
  34. return "返回值-CallableTest.call()";  
    35. 
  
  
  
  35. }  
    36. 
  
  
  
  36. }  
    37. 
  
  
  
  37. import java.util.concurrent.*; 
    38. 
  
  
  
  38. public class ExecutorTest { 
    39. 
  
  
  
  39. public static void main(String[] args) throws 
    InterruptedException, 
    40. 
  
  
  
  40. ExecutionException { 
    41. 
  
  
  
  41. ExecutorService es = Executors.newSingleThreadExecutor(); 
    42. 
  
  
  
  42. Future fr = es.submit(new RunnableTest());// 提交任务 
    43. 
  
  
  
  43. Future fc = es.submit(new CallableTest());// 提交任务 
    44. 
  
  
  
  44. // 取得返回值并输出 
    45. 
  
  
  
  45. System.out.println((String) fc.get()); 
    46. 
  
  
  
  46. // 检查任务是否执行完毕 
    47. 
  
  
  
  47. if (fr.isDone()) { 
    48. 
  
  
  
  48. System.out.println("执行完毕-RunnableTest.run()"); 
    49. 
  
  
  
  49. } else { 
    50. 
  
  
  
  50. System.out.println("未执行完-RunnableTest.run()"); 
    51. 
  
  
  
  51. } 
    52. 
  
  
  
  52. // 检查任务是否执行完毕 
    53. 
  
  
  
  53. if (fc.isDone()) { 
    54. 
  
  
  
  54. System.out.println("执行完毕-CallableTest.run()"); 
    55. 
  
  
  
  55. } else { 
    56. 
  
  
  
  56. System.out.println("未执行完-CallableTest.run()"); 
    57. 
  
  
  
  57. } 
    58. 
  
  
  
  58. // 停止线程池服务 
    59. 
  
  
  
  59. es.shutdown(); 
    60. 
  
  
  
  60. } 
    61. 
  
  
  
  61. } 
    62. 
  
  
  
  62. class RunnableTest implements Runnable { 
    63. 
  
  
  
  63. public void run() { 
    64. 
  
  
  
  64. System.out.println("已经执行-RunnableTest.run()"); 
    65. 
  
  
  
  65. } 
    66. 
  
  
  
  66. } 
    67. 
  
  
  
  67. class CallableTest implements Callable { 
    68. 
  
  
  
  68. public Object call() { 
    69. 
  
  
  
  69. System.out.println("已经执行-CallableTest.call()"); 
    70. 
  
  
  
  70. return "返回值-CallableTest.call()"; 
    71. 
  
  
  
  71. } 
    72. 
  
  
  
  72. }
    73.

运行结果：

已经执行-RunnableTest.run()
已经执行-CallableTest.call()
返回值-CallableTest.call()
执行完毕-RunnableTest.run()
执行完毕-CallableTest.run()

使用完Java线程池后，需要调用它的shutdown()方法停止服务，否则其中的所有线程都会保持运行，程序不会退出。

文章标题：Java线程池在运行后的结果反查
文章源于：http://www.csdahua.cn/qtweb/news11/402811.html

网站建设、网络推广公司-快上网，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 快上网

成都快上网为您推荐相关内容

建站公司知识

行业网站建设

重庆托管服务器　　 　注册域名　　 　成都网站建设　　 　护栏打桩机　　 　平武做网站　　 　时嘉做网站　　 　成都防护栏　　 　营销网站建设　　 　雕琢时光茶叶　　 　营山产后护理服务　　 　眉山电信机房托管　　 　定制网站　　 　新华建筑装饰　　 　温江网站建设　　 　ssl数字证书　　 　雅安电信机房　　 　德阳电信服务器托管　　 　成都网站制作　　 　胜锦安防科技　　 　成都未宇聚