這篇文章將為大家詳細講解有關JAVA中怎么使用Lock與Condition實現(xiàn)排它同步通信,文章內容質量較高,因此小編分享給大家做個參考,希望大家閱讀完這篇文章后對相關知識有一定的了解。
創(chuàng)新互聯(lián)公司專注于銅鼓網(wǎng)站建設服務及定制,我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗。 熱誠為您提供銅鼓營銷型網(wǎng)站建設,銅鼓網(wǎng)站制作、銅鼓網(wǎng)頁設計、銅鼓網(wǎng)站官網(wǎng)定制、微信小程序定制開發(fā)服務,打造銅鼓網(wǎng)絡公司原創(chuàng)品牌,更為您提供銅鼓網(wǎng)站排名全網(wǎng)營銷落地服務。
package com.study; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class Demo { public static void main(String[] args) { Demo demo = new Demo(); final OutPutClass putPutClass = demo.new OutPutClass(); Thread thread = new Thread(new Runnable() { @Override public void run() { while (true) { putPutClass.ins(); } } }); thread.start(); Thread thread2 = new Thread(new Runnable() { @Override public void run() { while (true) { putPutClass.des(); } } }); thread2.start(); } class OutPutClass { Lock lock = new ReentrantLock(); Condition condition = lock.newCondition(); private boolean isSync = true; public void ins() { lock.lock(); try { while (!isSync) { condition.await(); } Thread.sleep(1000L); System.out.println("正在上傳中...."); isSync = false; condition.signal(); } catch (InterruptedException e) { e.printStackTrace(); } finally { lock.unlock(); } } public void des() { lock.lock(); try { while (isSync) { condition.await(); Thread.sleep(1000L); } System.out.println("下載結束...."); isSync = true; condition.signal(); } catch (InterruptedException e) { e.printStackTrace(); } finally{ lock.unlock(); } } } }
關于JAVA中怎么使用Lock與Condition實現(xiàn)排它同步通信就分享到這里了,希望以上內容可以對大家有一定的幫助,可以學到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。
當前名稱:JAVA中怎么使用Lock與Condition實現(xiàn)排它同步通信
當前路徑:http://www.muchs.cn/article14/jpjege.html
成都網(wǎng)站建設公司_創(chuàng)新互聯(lián),為您提供微信公眾號、搜索引擎優(yōu)化、小程序開發(fā)、企業(yè)建站、移動網(wǎng)站建設、網(wǎng)站策劃
聲明:本網(wǎng)站發(fā)布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經(jīng)允許不得轉載,或轉載時需注明來源: 創(chuàng)新互聯(lián)