国产成人精品久久免费动漫-国产成人精品天堂-国产成人精品区在线观看-国产成人精品日本-a级毛片无码免费真人-a级毛片毛片免费观看久潮喷

您的位置:首頁技術文章
文章詳情頁

Java判斷線程池線程是否執行完畢

瀏覽:2日期:2022-09-01 10:18:32

在使用多線程的時候有時候我們會使用 java.util.concurrent.Executors的線程池,當多個線程異步執行的時候,我們往往不好判斷是否線程池中所有的子線程都已經執行完畢,但有時候這種判斷卻很有用,例如我有個方法的功能是往一個文件異步地寫入內容,我需要在所有的子線程寫入完畢后在文件末尾寫“---END---”及關閉文件流等,這個時候我就需要某個標志位可以告訴我是否線程池中所有的子線程都已經執行完畢,我使用這種方式來判斷。

public class MySemaphore { public static void main(String[] args) throws IOException, InterruptedException { final File stream = new File('c:tempstonefengstream.txt'); final OutputStream os = new FileOutputStream(stream); final OutputStreamWriter writer = new OutputStreamWriter(os); final Semaphore semaphore = new Semaphore(10); ExecutorService exec = Executors.newCachedThreadPool(); final long start = System.currentTimeMillis(); for (int i = 0; i < 10000000; i++) { final int num = i; Runnable task = new Runnable() {@Overridepublic void run() { try { semaphore.acquire(); writer.write(String.valueOf(num)+'n'); semaphore.release(); } catch (IOException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); }} }; exec.submit(task); } exec.shutdown(); while(true){ if(exec.isTerminated()){writer.write('---END---n');writer.close();System.out.println('所有的子線程都結束了!');break; } Thread.sleep(1000); } final long end = System.currentTimeMillis(); System.out.println((end-start)/1000); }}

當調用ExecutorService.shutdown方法的時候,線程池不再接收任何新任務,但此時線程池并不會立刻退出,直到添加到線程池中的任務都已經處理完成,才會退出。在調用shutdown方法后我們可以在一個死循環里面用isTerminated方法判斷是否線程池中的所有線程已經執行完畢,如果子線程都結束了,我們就可以做關閉流等后續操作了。

判斷線程池中的線程是否全部執行完畢的另外一種解決方案則是使用閉鎖(CountDownLatch)來實現,CountDownLatch是一種靈活的閉鎖實現,它可以使一個或多個線程等待一組事件發生。閉鎖狀態包括一個計數器,該計數器被初始化為一個正數,表示需要等待的事件數量。countDown方法遞減計數器,表示有一個事件已經發生了,而await方法等待計數器達到零,即表示需要等待的事情都已經發生。可以使用閉鎖來這樣設計程序達到目的:

public class CountDownLatchApproach { public static void main(String[] args) throws IOException, InterruptedException { final int nThreads = 10; final CountDownLatch endGate = new CountDownLatch(nThreads); final File stream = new File('c:tempstonefengstream.txt'); final OutputStream os = new FileOutputStream(stream); final OutputStreamWriter writer = new OutputStreamWriter(os); ExecutorService exec = Executors.newCachedThreadPool(); for (int i = 0; i < nThreads; i++) { final int num = i; Runnable task = new Runnable() {@Overridepublic void run() { try { writer.write(String.valueOf(num)+'n'); } catch (IOException e) { e.printStackTrace(); } finally { endGate.countDown(); }} }; exec.submit(task); } endGate.await(); writer.write('---END---n'); writer.close(); }}

這種解決方案雖然可以達到目的但是性能差到沒朋友,我更傾向于使用第一種方案。

現在我們有了更優雅的第三種方案,它的執行性能也不錯。

public class MySemaphore { public static void main(String[] args) throws IOException, InterruptedException { final File stream = new File('c:tempstonefengstream.txt'); final OutputStream os = new FileOutputStream(stream); final OutputStreamWriter writer = new OutputStreamWriter(os); final Semaphore semaphore = new Semaphore(10); ExecutorService exec = Executors.newCachedThreadPool(); final long start = System.currentTimeMillis(); for (int i = 0; i < 10000000; i++) { final int num = i; Runnable task = new Runnable() {@Overridepublic void run() { try { semaphore.acquire(); writer.write(String.valueOf(num)+'n'); semaphore.release(); } catch (IOException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); }} }; exec.submit(task); } exec.shutdown(); exec.awaitTermination(1, TimeUnit.HOURS); writer.write('---END---n'); writer.close(); System.out.println('ËùÓеÄ×ÓÏ̶߳¼½áÊøÁË£¡'); final long end = System.currentTimeMillis(); System.out.println((end-start)/1000); }}

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網。

標簽: Java
相關文章:
主站蜘蛛池模板: 成人做爰免费网站 | 久久99久久精品免费思思6 | 欧美亚洲日本在线 | 成年女人永久免费观看片 | 亚洲精品成人一区 | 久久综合免费 | 国产三级网站 | 永久免费精品视频 | 国产9191精品免费观看 | 久久爱噜噜噜噜久久久网 | 欧美激情国产一区在线不卡 | 精品国产成人a区在线观看 精品国产成人a在线观看 | 韩国欧洲一级毛片 | 亚洲精品日韩一区二区 | 成人毛片手机版免费看 | 日韩在线视频免费不卡一区 | 中文字幕色站 | 在线综合视频 | 亚洲欧美久久精品 | 手机看片手机在线看片 | 热re91久久精品国产91热 | 国产在线精品福利91香蕉 | 最新中文字幕一区二区乱码 | 国产成人精品一区二区视频 | 国产精自产拍久久久久久蜜 | 亚洲天堂网在线观看视频 | 新婚第一次一级毛片 | 欧美精品免费线视频观看视频 | 99er精品| 玖玖这里只有精品 | 一级欧美日韩 | 二级黄的全免费视频 | 在线天天干 | 亚洲视频黄 | 欧美线在线精品观看视频 | 写真片福利视频在线播放 | 亚洲综合免费视频 | 特级片在线观看 | 久久精品国产99久久 | 91精品久久一区二区三区 | 99热国产免费 |