日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢(xún)
選擇下列產(chǎn)品馬上在線(xiàn)溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問(wèn)題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷(xiāo)解決方案
Java線(xiàn)程池在運(yùn)行后的結(jié)果反查

Java線(xiàn)程池需要不斷的學(xué)習(xí)，在學(xué)習(xí)的時(shí)候我們就要注意不少的問(wèn)題。下面我們就來(lái)看看具體的語(yǔ)言運(yùn)作環(huán)境如何才能滿(mǎn)足Java線(xiàn)程池相關(guān)程序的運(yùn)行。希望大家有所收獲。

澤庫(kù)網(wǎng)站制作公司哪家好，找創(chuàng)新互聯(lián)！從網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)站建設(shè)、微信開(kāi)發(fā)、APP開(kāi)發(fā)、響應(yīng)式網(wǎng)站設(shè)計(jì)等網(wǎng)站項(xiàng)目制作，到程序開(kāi)發(fā)，運(yùn)營(yíng)維護(hù)。創(chuàng)新互聯(lián)2013年開(kāi)創(chuàng)至今到現(xiàn)在10年的時(shí)間，我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn)，來(lái)保證我們的工作的順利進(jìn)行。專(zhuān)注于網(wǎng)站建設(shè)就選創(chuàng)新互聯(lián)。

無(wú)論是接收Runnable型參數(shù)，還是接收Callable型參數(shù)的submit()方法，都會(huì)返回一個(gè)Future（也是一個(gè)接口）類(lèi)型的對(duì)象。該對(duì)象中包含了任務(wù)的執(zhí)行情況以及結(jié)果。調(diào)用Future的boolean isDone()方法可以獲知任務(wù)是否執(zhí)行完畢；調(diào)用Object get()方法可以獲得任務(wù)執(zhí)行后的返回結(jié)果，如果此時(shí)任務(wù)還沒(méi)有執(zhí)行完，get()方法會(huì)保持等待，直到相應(yīng)的任務(wù)執(zhí)行完畢后，才會(huì)將結(jié)果返回。

我們用下面的一個(gè)例子來(lái)演示Java5.0中Java線(xiàn)程池的使用：

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());// 提交任務(wù)  
    7. 
  
  
  
  7. Future fc = es.submit(new CallableTest());// 提交任務(wù)  
    8. 
  
  
  
  8. // 取得返回值并輸出  
    9. 
  
  
  
  9. System.out.println((String) fc.get());  
    10. 
  
  
  
  10. // 檢查任務(wù)是否執(zhí)行完畢  
    11. 
  
  
  
  11. if (fr.isDone()) {  
    12. 
  
  
  
  12. System.out.println("執(zhí)行完畢-RunnableTest.run()");  
    13. 
  
  
  
  13. } else {  
    14. 
  
  
  
  14. System.out.println("未執(zhí)行完-RunnableTest.run()");  
    15. 
  
  
  
  15. }  
    16. 
  
  
  
  16. // 檢查任務(wù)是否執(zhí)行完畢  
    17. 
  
  
  
  17. if (fc.isDone()) {  
    18. 
  
  
  
  18. System.out.println("執(zhí)行完畢-CallableTest.run()");  
    19. 
  
  
  
  19. } else {  
    20. 
  
  
  
  20. System.out.println("未執(zhí)行完-CallableTest.run()");  
    21. 
  
  
  
  21. }  
    22. 
  
  
  
  22. // 停止線(xiàn)程池服務(wù)  
    23. 
  
  
  
  23. es.shutdown();  
    24. 
  
  
  
  24. }  
    25. 
  
  
  
  25. }  
    26. 
  
  
  
  26. class RunnableTest implements Runnable {  
    27. 
  
  
  
  27. public void run() {  
    28. 
  
  
  
  28. System.out.println("已經(jīng)執(zhí)行-RunnableTest.run()");  
    29. 
  
  
  
  29. }  
    30. 
  
  
  
  30. }  
    31. 
  
  
  
  31. class CallableTest implements Callable {  
    32. 
  
  
  
  32. public Object call() {  
    33. 
  
  
  
  33. System.out.println("已經(jīng)執(zhí)行-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());// 提交任務(wù) 
    43. 
  
  
  
  43. Future fc = es.submit(new CallableTest());// 提交任務(wù) 
    44. 
  
  
  
  44. // 取得返回值并輸出 
    45. 
  
  
  
  45. System.out.println((String) fc.get()); 
    46. 
  
  
  
  46. // 檢查任務(wù)是否執(zhí)行完畢 
    47. 
  
  
  
  47. if (fr.isDone()) { 
    48. 
  
  
  
  48. System.out.println("執(zhí)行完畢-RunnableTest.run()"); 
    49. 
  
  
  
  49. } else { 
    50. 
  
  
  
  50. System.out.println("未執(zhí)行完-RunnableTest.run()"); 
    51. 
  
  
  
  51. } 
    52. 
  
  
  
  52. // 檢查任務(wù)是否執(zhí)行完畢 
    53. 
  
  
  
  53. if (fc.isDone()) { 
    54. 
  
  
  
  54. System.out.println("執(zhí)行完畢-CallableTest.run()"); 
    55. 
  
  
  
  55. } else { 
    56. 
  
  
  
  56. System.out.println("未執(zhí)行完-CallableTest.run()"); 
    57. 
  
  
  
  57. } 
    58. 
  
  
  
  58. // 停止線(xiàn)程池服務(wù) 
    59. 
  
  
  
  59. es.shutdown(); 
    60. 
  
  
  
  60. } 
    61. 
  
  
  
  61. } 
    62. 
  
  
  
  62. class RunnableTest implements Runnable { 
    63. 
  
  
  
  63. public void run() { 
    64. 
  
  
  
  64. System.out.println("已經(jīng)執(zhí)行-RunnableTest.run()"); 
    65. 
  
  
  
  65. } 
    66. 
  
  
  
  66. } 
    67. 
  
  
  
  67. class CallableTest implements Callable { 
    68. 
  
  
  
  68. public Object call() { 
    69. 
  
  
  
  69. System.out.println("已經(jīng)執(zhí)行-CallableTest.call()"); 
    70. 
  
  
  
  70. return "返回值-CallableTest.call()"; 
    71. 
  
  
  
  71. } 
    72. 
  
  
  
  72. }
    73.

運(yùn)行結(jié)果：

已經(jīng)執(zhí)行-RunnableTest.run()
已經(jīng)執(zhí)行-CallableTest.call()
返回值-CallableTest.call()
執(zhí)行完畢-RunnableTest.run()
執(zhí)行完畢-CallableTest.run()

使用完Java線(xiàn)程池后，需要調(diào)用它的shutdown()方法停止服務(wù)，否則其中的所有線(xiàn)程都會(huì)保持運(yùn)行，程序不會(huì)退出。


網(wǎng)頁(yè)標(biāo)題：Java線(xiàn)程池在運(yùn)行后的結(jié)果反查
文章出自：http://www.5511xx.com/article/cdcgohs.html