保護(hù)性暫停-增強(qiáng)超時(shí)

import com.sun.corba.se.impl.orbutil.concurrent.Sync; import lombok.Synchronized; import lombok.extern.slf4j.Slf4j;@Slf4j(topic = "c.Test20") public class Test20 {public static void main(String[] args) {// 線程1等待線程2的下載結(jié)果GuardedObject guardedObject = new GuardedObject();new Thread(()->{log.debug("等待結(jié)果");Object object = guardedObject.get(2000);log.debug("結(jié)果大小:{}",object);},"t1").start();new Thread(()->{log.debug("執(zhí)行下載");Object object = new Object();try {Thread.sleep(5000);guardedObject.complete(object);} catch (InterruptedException e) {e.printStackTrace();}},"t2").start();} }class GuardedObject{private Object response;// 最多等多久public Object get(long timeout){synchronized (this){// 開始時(shí)間long begin = System.currentTimeMillis();long passedTime = 0;while(null == response){long waitTime = timeout - passedTime;if(waitTime<=0){break;}try {this.wait(waitTime);} catch (InterruptedException e) {e.printStackTrace();}// 求得經(jīng)歷時(shí)間passedTime = System.currentTimeMillis()-begin;}}return response;}public void complete(Object response){synchronized (this){this.response = response;this.notifyAll();}} }

總結(jié)

以上是生活随笔為你收集整理的JUC并发编程七 并发架构--wait/notify的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。