Java澶氱嚎紼嬬郴鍒?-鈥淛UC閿佲€?8涔?鍏變韓閿佸拰ReentrantReadWriteLock-嫻庡崡杞歡寮€鍙憒灞變笢杞歡寮€鍙?嫻庡崡璧㈠痙縐戞妧杞歡寮€鍙戝叕鍙?/title> <meta name="keywords" content="Java澶氱嚎紼嬬郴鍒?-鈥淛UC閿佲€?8涔?鍏變韓閿佸拰ReentrantReadWriteLock"/> <meta name="description" content="姒傝Java鐨凧UC(java.util.concurrent)鍖呬腑鐨勯攣鍖呮嫭"鐙崰閿?quot;鍜?quot;鍏變韓閿?quot;銆傚湪鈥淛ava澶氱嚎紼嬬郴鍒?-鈥淛UC閿佲€?2涔嬩簰鏂ラ攣ReentrantLock鈥濅腑錛屽Java鐨勭嫭鍗犻攣榪涜浜嗚鏄庛€傛湰绔犲Java鐨勨€滃叡浜攣鈥濊繘琛屼粙緇嶏紝JUC涓殑鍏變韓閿佹湁Coun"/> <link href="/css/style.css" rel="stylesheet" type="text/css" /> <meta http-equiv="Cache-Control" content="no-transform" /> <meta http-equiv="Cache-Control" content="no-siteapp" /> </head> <body> <div style="position:fixed;left:-9000px;top:-9000px;"><dfn id="orz4q"><noscript id="orz4q"><xmp id="orz4q"><output id="orz4q"></output></xmp></noscript></dfn><dl id="orz4q"></dl><ol id="orz4q"><nav id="orz4q"><pre id="orz4q"></pre></nav></ol><dfn id="orz4q"></dfn><optgroup id="orz4q"></optgroup><center id="orz4q"><track id="orz4q"><rp id="orz4q"></rp></track></center><table id="orz4q"><ruby id="orz4q"><dl id="orz4q"><del id="orz4q"></del></dl></ruby></table><rt id="orz4q"></rt><output id="orz4q"></output><dl id="orz4q"></dl><div id="orz4q"></div><optgroup id="orz4q"></optgroup><address id="orz4q"><progress id="orz4q"><noframes id="orz4q"><tr id="orz4q"></tr></noframes></progress></address><listing id="orz4q"><thead id="orz4q"><address id="orz4q"></address></thead></listing><video id="orz4q"></video><object id="orz4q"></object><div id="orz4q"></div><progress id="orz4q"><listing id="orz4q"><th id="orz4q"><option id="orz4q"></option></th></listing></progress><meter id="orz4q"></meter><acronym id="orz4q"><rt id="orz4q"></rt></acronym><label id="orz4q"></label><track id="orz4q"></track><noscript id="orz4q"><div id="orz4q"><pre id="orz4q"><ol id="orz4q"></ol></pre></div></noscript><s id="orz4q"><kbd id="orz4q"></kbd></s><form id="orz4q"></form><var id="orz4q"></var><dl id="orz4q"><strike id="orz4q"></strike></dl><xmp id="orz4q"><strike id="orz4q"><samp id="orz4q"></samp></strike></xmp><listing id="orz4q"><thead id="orz4q"><address id="orz4q"><progress id="orz4q"></progress></address></thead></listing><del id="orz4q"></del><object id="orz4q"><address id="orz4q"><samp id="orz4q"><rt id="orz4q"></rt></samp></address></object><ruby id="orz4q"></ruby><noframes id="orz4q"></noframes><code id="orz4q"></code><var id="orz4q"></var><nav id="orz4q"></nav><li id="orz4q"></li><tbody id="orz4q"><table id="orz4q"><dl id="orz4q"></dl></table></tbody><optgroup id="orz4q"><xmp id="orz4q"><big id="orz4q"></big></xmp></optgroup><var id="orz4q"></var><nav id="orz4q"></nav><rt id="orz4q"></rt><dfn id="orz4q"><td id="orz4q"></td></dfn><s id="orz4q"></s><pre id="orz4q"><rp id="orz4q"></rp></pre><rt id="orz4q"><tr id="orz4q"></tr></rt> <pre id="orz4q"></pre><rt id="orz4q"><tr id="orz4q"><output id="orz4q"></output></tr></rt><xmp id="orz4q"><pre id="orz4q"></pre></xmp><td id="orz4q"><tbody id="orz4q"></tbody></td><code id="orz4q"><video id="orz4q"><track id="orz4q"><tt id="orz4q"></tt></track></video></code><thead id="orz4q"></thead><source id="orz4q"><cite id="orz4q"><td id="orz4q"></td></cite></source><del id="orz4q"></del><code id="orz4q"></code><code id="orz4q"><menu id="orz4q"></menu></code><legend id="orz4q"><button id="orz4q"><source id="orz4q"></source></button></legend><delect id="orz4q"></delect><ins id="orz4q"></ins><pre id="orz4q"></pre><table id="orz4q"><noframes id="orz4q"></noframes></table><source id="orz4q"></source><optgroup id="orz4q"></optgroup><dl id="orz4q"></dl><center id="orz4q"><track id="orz4q"><rp id="orz4q"></rp></track></center><address id="orz4q"></address><tt id="orz4q"><code id="orz4q"></code></tt><delect id="orz4q"></delect><strike id="orz4q"></strike><optgroup id="orz4q"><xmp id="orz4q"><big id="orz4q"></big></xmp></optgroup><menu id="orz4q"></menu><menu id="orz4q"></menu><optgroup id="orz4q"></optgroup><input id="orz4q"><label id="orz4q"></label></input><big id="orz4q"><track id="orz4q"><button id="orz4q"></button></track></big><nav id="orz4q"><blockquote id="orz4q"></blockquote></nav><listing id="orz4q"><thead id="orz4q"><address id="orz4q"></address></thead></listing><tbody id="orz4q"><table id="orz4q"></table></tbody><meter id="orz4q"><tbody id="orz4q"></tbody></meter><dl id="orz4q"><strike id="orz4q"><samp id="orz4q"></samp></strike></dl><noscript id="orz4q"></noscript><input id="orz4q"></input><legend id="orz4q"></legend><address id="orz4q"><progress id="orz4q"><noframes id="orz4q"><tr id="orz4q"></tr></noframes></progress></address><dfn id="orz4q"><td id="orz4q"></td></dfn><center id="orz4q"><ol id="orz4q"><noscript id="orz4q"></noscript></ol></center> <s id="orz4q"></s><s id="orz4q"></s><output id="orz4q"></output><ruby id="orz4q"></ruby><ins id="orz4q"></ins><s id="orz4q"><kbd id="orz4q"></kbd></s><strike id="orz4q"></strike><input id="orz4q"><label id="orz4q"></label></input><form id="orz4q"></form><tbody id="orz4q"><table id="orz4q"><legend id="orz4q"><dl id="orz4q"></dl></legend></table></tbody><tr id="orz4q"></tr><dd id="orz4q"></dd><li id="orz4q"></li><code id="orz4q"></code><menu id="orz4q"><samp id="orz4q"></samp></menu><rp id="orz4q"></rp><pre id="orz4q"></pre><tbody id="orz4q"><table id="orz4q"></table></tbody><ol id="orz4q"><label id="orz4q"><blockquote id="orz4q"></blockquote></label></ol><tr id="orz4q"><option id="orz4q"></option></tr><legend id="orz4q"></legend><rp id="orz4q"><output id="orz4q"></output></rp><menu id="orz4q"></menu><rt id="orz4q"></rt><rp id="orz4q"></rp><optgroup id="orz4q"></optgroup><del id="orz4q"></del><button id="orz4q"></button><rp id="orz4q"></rp><dfn id="orz4q"><td id="orz4q"></td></dfn><nav id="orz4q"><blockquote id="orz4q"></blockquote></nav><thead id="orz4q"><menuitem id="orz4q"><progress id="orz4q"><noscript id="orz4q"></noscript></progress></menuitem></thead><acronym id="orz4q"></acronym><center id="orz4q"></center><noscript id="orz4q"><div id="orz4q"></div></noscript><noscript id="orz4q"></noscript><meter id="orz4q"></meter><optgroup id="orz4q"><xmp id="orz4q"><big id="orz4q"></big></xmp></optgroup><nav id="orz4q"></nav><input id="orz4q"><label id="orz4q"><menuitem id="orz4q"><progress id="orz4q"></progress></menuitem></label></input><address id="orz4q"></address><dl id="orz4q"></dl><progress id="orz4q"></progress><video id="orz4q"></video></div> <div class="head"> <div class="top"><a href="/html/sitemap.xml">XML</a> | <a href="/html/sitemap.html">HTML</a> | <a href="/sitemap.txt">TXT</a></div> <div class="bank"> <div class="logo"> <h1><a href="http://www.themmauniversity.com" style="margin-right:10px">嫻庡崡杞歡寮€鍙?/a><a href="http://www.themmauniversity.com">灞變笢杞歡寮€鍙?/a></h1> </div> <div class="contact-top"></div> </div> <div class="menu"> <ul> <li><a href="/">棣?#160; 欏?/a></li> <li><a href="/About/">鍏充簬鎴戜滑</a></li> <li><a href="/Advantage/">寮€鍙戜紭鍔?/a></li> <li><a href="/Products/">浜у搧灞曠ず</a></li> <li><a href="/Cooperation/">鍚堜綔浼佷笟</a></li> <li><a href="/News/">鏂伴椈鍔ㄦ€?/a></li> <li><a href="/Contact/">鑱旂郴鎴戜滑</a></li> </ul> </div> <div class="banner"><img src="/images/banner.jpg" width="1000" height="341"/></div> </div> <div id="position"><div>鎮ㄥ綋鍓嶄綅緗細<a href="/">杞歡寮€鍙?/a> >> <a href="/News/">鏂伴椈鍔ㄦ€?/a> >> <a href="/News/Technology/">杞歡寮€鍙戞妧鏈?/a> >> 嫻忚鏂囩珷</div></div> <div class="youshi_f1" id="youshi_tdyx"> <div class="youshi01"> <h1 class="article_title">Java澶氱嚎紼嬬郴鍒?-鈥淛UC閿佲€?8涔?鍏變韓閿佸拰ReentrantReadWriteLock</h1> <div class="article_author">娣誨姞鏃墮棿錛?016-12-20 17:17:30 鏂囩珷浣滆€咃細<a href="/">嫻庡崡杞歡寮€鍙?/a> 嫻忚嬈℃暟錛?Script Language="Javascript" Src="/item/GetHits.asp?Action=Count&GetFlag=0&m=1&ID=3072"></Script></div> <div class="article_main"><div id="MyContent"><p style="margin-top: 0px; margin-bottom: 0px; padding: 15px 0px 0px; line-height: 30px; font-family: 瀹嬩綋; color: rgb(51, 51, 51); font-size: 13.3333px; white-space: normal; background-color: rgb(241, 241, 241);">姒傝Java鐨凧UC(java.util.concurrent)鍖呬腑鐨勯攣鍖呮嫭"鐙崰閿?quot;鍜?quot;鍏變韓閿?quot;銆傚湪鈥淛ava澶氱嚎紼嬬郴鍒?-鈥淛UC閿佲€?2涔?浜掓枼閿丷eentrantLock 鈥濅腑錛屽Java鐨勭嫭鍗犻攣榪涜浜嗚鏄庛€傛湰绔犲Java鐨勨€滃叡浜攣鈥濊繘琛屼粙緇嶏紝JUC涓殑鍏變韓閿佹湁CountDownLatch, CyclicBarrier, Semaphore, ReentrantReadWriteLock絳夛紱鏈珷浼氫互ReentrantReadWriteLock涓鴻摑鏈鍏變韓閿佽繘琛岃鏄庛€傚唴瀹瑰寘鎷細ReadWriteLock 鍜?ReentrantReadWriteLock浠嬬粛ReadWriteLock 鍜?ReentrantReadWriteLock鍑芥暟鍒楄〃鍙傝€冧唬鐮?鍩轟簬JDK1.7.0_40) 鑾峰彇鍏變韓閿?/p> 閲婃斁鍏變韓閿?/p> 鍏鉤鍏變韓閿佸拰闈炲叕騫沖叡浜攣ReentrantReadWriteLock紺轟緥 ReadWriteLock 鍜?ReentrantReadWriteLock浠嬬粛ReadWriteLock錛岄【鍚嶆€濅箟錛屾槸璇誨啓閿併€傚畠緇存姢浜嗕竴瀵圭浉鍏崇殑閿?鈥?鈥?鈥滆鍙栭攣鈥濆拰鈥滃啓鍏ラ攣鈥濓紝涓€涓敤浜庤鍙栨搷浣滐紝鍙︿竴涓敤浜庡啓鍏ユ搷浣溿€?/p>鈥滆鍙栭攣鈥濈敤浜庡彧璇繪搷浣滐紝瀹冩槸鈥滃叡浜攣鈥濓紝鑳藉悓鏃惰澶氫釜綰跨▼鑾峰彇銆?/p>鈥滃啓鍏ラ攣鈥濈敤浜庡啓鍏ユ搷浣滐紝瀹冩槸鈥滅嫭鍗犻攣鈥濓紝鍐欏叆閿佸彧鑳借涓€涓嚎紼嬮攣鑾峰彇銆?/p>娉ㄦ剰錛氫笉鑳藉悓鏃跺瓨鍦ㄨ鍙栭攣鍜屽啓鍏ラ攣錛?/p>ReadWriteLock鏄竴涓帴鍙ｃ€俁eentrantReadWriteLock鏄畠鐨勫疄鐜扮被錛孯eentrantReadWriteLock鍖呮嫭瀛愮被ReadLock鍜學riteLock銆?/p> ReadWriteLock 鍜?ReentrantReadWriteLock鍑芥暟鍒楄〃ReadWriteLock鍑芥暟鍒楄〃 // 榪斿洖鐢ㄤ簬璇誨彇鎿嶄綔鐨勯攣銆?/p>Lock readLock()// 榪斿洖鐢ㄤ簬鍐欏叆鎿嶄綔鐨勯攣銆?/p>Lock writeLock() ReentrantReadWriteLock鍑芥暟鍒楄〃 澶嶅埗浠ｇ爜// 鍒涘緩涓€涓柊鐨?ReentrantReadWriteLock錛岄粯璁ゆ槸閲囩敤鈥滈潪鍏鉤絳栫暐鈥濄€?/p>ReentrantReadWriteLock()// 鍒涘緩涓€涓柊鐨?ReentrantReadWriteLock錛宖air鏄€滃叕騫崇瓥鐣モ€濄€俧air涓簍rue錛屾剰鍛崇潃鍏鉤絳栫暐錛涘惁鍒欙紝鎰忓懗鐫€闈炲叕騫崇瓥鐣ャ€?/p>ReentrantReadWriteLock(boolean fair) // 榪斿洖褰撳墠鎷ユ湁鍐欏叆閿佺殑綰跨▼錛屽鏋滄病鏈夎繖鏍風殑綰跨▼錛屽垯榪斿洖 null銆?/p>protected Thread getOwner()// 榪斿洖涓€涓?collection錛屽畠鍖呭惈鍙兘姝ｅ湪絳夊緟鑾峰彇璇誨彇閿佺殑綰跨▼銆?/p>protected Collection<Thread> getQueuedReaderThreads()// 榪斿洖涓€涓?collection錛屽畠鍖呭惈鍙兘姝ｅ湪絳夊緟鑾峰彇璇誨彇鎴栧啓鍏ラ攣鐨勭嚎紼嬨€?/p>protected Collection<Thread> getQueuedThreads()// 榪斿洖涓€涓?collection錛屽畠鍖呭惈鍙兘姝ｅ湪絳夊緟鑾峰彇鍐欏叆閿佺殑綰跨▼銆?/p>protected Collection<Thread> getQueuedWriterThreads()// 榪斿洖絳夊緟鑾峰彇璇誨彇鎴栧啓鍏ラ攣鐨勭嚎紼嬩及璁℃暟鐩€?/p>int getQueueLength()// 鏌ヨ褰撳墠綰跨▼鍦ㄦ閿佷笂淇濇寔鐨勯噸鍏ヨ鍙栭攣鏁伴噺銆?/p>int getReadHoldCount()// 鏌ヨ涓烘閿佷繚鎸佺殑璇誨彇閿佹暟閲忋€?/p>int getReadLockCount()// 榪斿洖涓€涓?collection錛屽畠鍖呭惈鍙兘姝ｅ湪絳夊緟涓庡啓鍏ラ攣鐩稿叧鐨勭粰瀹氭潯浠剁殑閭ｄ簺綰跨▼銆?/p>protected Collection<Thread> getWaitingThreads(Condition condition)// 榪斿洖姝ｇ瓑寰呬笌鍐欏叆閿佺浉鍏崇殑緇欏畾鏉′歡鐨勭嚎紼嬩及璁℃暟鐩€?/p>int getWaitQueueLength(Condition condition)// 鏌ヨ褰撳墠綰跨▼鍦ㄦ閿佷笂淇濇寔鐨勯噸鍏ュ啓鍏ラ攣鏁伴噺銆?/p>int getWriteHoldCount()// 鏌ヨ鏄惁緇欏畾綰跨▼姝ｅ湪絳夊緟鑾峰彇璇誨彇鎴栧啓鍏ラ攣銆?/p>boolean hasQueuedThread(Thread thread)// 鏌ヨ鏄惁鎵€鏈夌殑綰跨▼姝ｅ湪絳夊緟鑾峰彇璇誨彇鎴栧啓鍏ラ攣銆?/p>boolean hasQueuedThreads()// 鏌ヨ鏄惁鏈変簺綰跨▼姝ｅ湪絳夊緟涓庡啓鍏ラ攣鏈夊叧鐨勭粰瀹氭潯浠躲€?/p>boolean hasWaiters(Condition condition)// 濡傛灉姝ら攣灝嗗叕騫蟲€ц緗負 ture錛屽垯榪斿洖 true銆?/p>boolean isFair()// 鏌ヨ鏄惁鏌愪釜綰跨▼淇濇寔浜嗗啓鍏ラ攣銆?/p>boolean isWriteLocked()// 鏌ヨ褰撳墠綰跨▼鏄惁淇濇寔浜嗗啓鍏ラ攣銆?/p>boolean isWriteLockedByCurrentThread()// 榪斿洖鐢ㄤ簬璇誨彇鎿嶄綔鐨勯攣銆?/p>ReentrantReadWriteLock.ReadLock readLock()// 榪斿洖鐢ㄤ簬鍐欏叆鎿嶄綔鐨勯攣銆?/p>ReentrantReadWriteLock.WriteLock writeLock()澶嶅埗浠ｇ爜 鍙傝€冧唬鐮?鍩轟簬JDK1.7.0_40)ReentrantReadWriteLock鐨勫畬鏁?a target="_blank" style="margin: 0px; padding: 0px; color: rgb(51, 51, 51); text-decoration: none;">婧愮爜</a> View Code AQS鐨勫畬鏁存簮鐮?/p> View Code 鍏朵腑錛屽叡浜攣婧愮爜鐩稿叧鐨勪唬鐮佸涓嬶細 澶嶅埗浠ｇ爜public static class ReadLock implements Lock, java.io.Serializable { private static final long serialVersionUID = -5992448646407690164L; // ReentrantReadWriteLock鐨凙QS瀵硅薄 private final Sync sync; protected ReadLock(ReentrantReadWriteLock lock) { sync = lock.sync; } // 鑾峰彇鈥滃叡浜攣鈥?/p> public void lock() { sync.acquireShared(1); } // 濡傛灉綰跨▼鏄腑鏂姸鎬侊紝鍒欐姏鍑轟竴鍦猴紝鍚﹀垯灝濊瘯鑾峰彇鍏變韓閿併€?/p> public void lockInterruptibly() throws InterruptedException { sync.acquireSharedInterruptibly(1); } // 灝濊瘯鑾峰彇鈥滃叡浜攣鈥?/p> public boolean tryLock() { return sync.tryReadLock(); } // 鍦ㄦ寚瀹氭椂闂村唴錛屽皾璇曡幏鍙栤€滃叡浜攣鈥?/p> public boolean tryLock(long timeout, TimeUnit unit) throws InterruptedException { return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); } // 閲婃斁鈥滃叡浜攣鈥?/p> public void unlock() { sync.releaseShared(1); } // 鏂板緩鏉′歡 public Condition newCondition() { throw new UnsupportedOperationException(); } public String toString() { int r = sync.getReadLockCount(); return super.toString() + "[Read locks = " + r + "]"; }}澶嶅埗浠ｇ爜璇存槑錛?/p>ReadLock涓殑sync鏄竴涓猄ync瀵硅薄錛孲ync緇ф壙浜嶢QS綾伙紝鍗砈ync灝辨槸涓€涓攣銆俁eentrantReadWriteLock涓篃鏈変竴涓猄ync瀵硅薄錛岃€屼笖ReadLock涓殑sync鍜孯eentrantReadWriteLock涓殑sync鏄搴斿叧緋匯€傚嵆ReentrantReadWriteLock鍜孯eadLock鍏變韓鍚屼竴涓狝QS瀵硅薄錛屽叡浜悓涓€鎶婇攣銆?/p>ReentrantReadWriteLock涓璖ync鐨勫畾涔夊涓嬶細 final Sync sync;涓嬮潰錛屽垎鍒粠鈥滆幏鍙栧叡浜攣鈥濆拰鈥滈噴鏀懼叡浜攣鈥濅袱涓柟闈㈠鍏變韓閿佽繘琛岃鏄庛€?/p> 鑾峰彇鍏變韓閿?/p>鑾峰彇鍏變韓閿佺殑鎬濇兂(鍗砽ock鍑芥暟鐨勬楠?錛屾槸鍏堥€氳繃tryAcquireShared()灝濊瘯鑾峰彇鍏變韓閿併€傚皾璇曟垚鍔熺殑璇濓紝鍒欑洿鎺ヨ繑鍥烇紱灝濊瘯澶辮觸鐨勮瘽錛屽垯閫氳繃doAcquireShared()涓嶆柇鐨勫驚鐜茍灝濊瘯鑾峰彇閿侊紝鑻ユ湁闇€瑕侊紝鍒欓樆濉炵瓑寰呫€俤oAcquireShared()鍦ㄥ驚鐜腑姣忔灝濊瘯鑾峰彇閿佹椂錛岄兘鏄€氳繃tryAcquireShared()鏉ヨ繘琛屽皾璇曠殑銆備笅闈㈢湅鐪嬧€滆幏鍙栧叡浜攣鈥濈殑璇︾粏嫻佺▼銆?/p> 1. lock() lock()鍦≧eadLock涓紝婧愮爜濡備笅錛?/p> public void lock() { sync.acquireShared(1);} 2. acquireShared() Sync緇ф壙浜嶢QS錛宎cquireShared()瀹氫箟鍦ˋQS涓€傛簮鐮佸涓嬶細 public final void acquireShared(int arg) { if (tryAcquireShared(arg) < 0) doAcquireShared(arg);}璇存槑錛歛cquireShared()棣栧厛浼氶€氳繃tryAcquireShared()鏉ュ皾璇曡幏鍙栭攣銆?/p>灝濊瘯鎴愬姛鐨勮瘽錛屽垯涓嶅啀鍋氫換浣曞姩浣?鍥犱負宸茬粡鎴愬姛鑾峰彇鍒伴攣浜?銆?/p>灝濊瘯澶辮觸鐨勮瘽錛屽垯閫氳繃doAcquireShared()鏉ヨ幏鍙栭攣銆俤oAcquireShared()浼氳幏鍙栧埌閿佷簡鎵嶈繑鍥炪€?/p> 3. tryAcquireShared() tryAcquireShared()瀹氫箟鍦≧eentrantReadWriteLock.java鐨凷ync涓紝婧愮爜濡備笅錛?/p> 澶嶅埗浠ｇ爜protected final int tryAcquireShared(int unused) { Thread current = Thread.currentThread(); // 鑾峰彇鈥滈攣鈥濈殑鐘舵€?/p> int c = getState(); // 濡傛灉鈥滈攣鈥濇槸鈥滀簰鏂ラ攣鈥濓紝騫朵笖鑾峰彇閿佺殑綰跨▼涓嶆槸current綰跨▼錛涘垯榪斿洖-1銆?/p> if (exclusiveCount(c) != 0 && getExclusiveOwnerThread() != current) return -1; // 鑾峰彇鈥滆鍙栭攣鈥濈殑鍏變韓璁℃暟 int r = sharedCount(c); // 濡傛灉鈥滀笉闇€瑕侀樆濉炵瓑寰呪€濓紝騫朵笖鈥滆鍙栭攣鈥濈殑鍏變韓璁℃暟灝忎簬MAX_COUNT錛?/p> // 鍒欓€氳繃CAS鍑芥暟鏇存柊鈥滈攣鐨勭姸鎬佲€濓紝灝嗏€滆鍙栭攣鈥濈殑鍏變韓璁℃暟+1銆?/p> if (!readerShouldBlock() && r < MAX_COUNT && compareAndSetState(c, c + SHARED_UNIT)) { // 絎?嬈¤幏鍙栤€滆鍙栭攣鈥濄€?/p> if (r == 0) { firstReader = current; firstReaderHoldCount = 1; // 濡傛灉鎯寵鑾峰彇閿佺殑綰跨▼(current)鏄1涓幏鍙栭攣(firstReader)鐨勭嚎紼?/p> } else if (firstReader == current) { firstReaderHoldCount++; } else { // HoldCounter鏄敤鏉ョ粺璁¤綰跨▼鑾峰彇鈥滆鍙栭攣鈥濈殑嬈℃暟銆?/p> HoldCounter rh = cachedHoldCounter; if (rh == null || rh.tid != current.getId()) cachedHoldCounter = rh = readHolds.get(); else if (rh.count == 0) readHolds.set(rh); // 灝嗚綰跨▼鑾峰彇鈥滆鍙栭攣鈥濈殑嬈℃暟+1銆?/p> rh.count++; } return 1; } return fullTryAcquireShared(current);}澶嶅埗浠ｇ爜璇存槑錛歵ryAcquireShared()鐨勪綔鐢ㄦ槸灝濊瘯鑾峰彇鈥滃叡浜攣鈥濄€?/p>濡傛灉鍦ㄥ皾璇曡幏鍙栭攣鏃訛紝鈥滀笉闇€瑕侀樆濉炵瓑寰呪€濆茍涓斺€滆鍙栭攣鐨勫叡浜 鏁板皬浜嶮AX_COUNT鈥濓紝鍒欑洿鎺ラ€氳繃CAS鍑芥暟鏇存柊鈥滆鍙栭攣鐨勫叡浜 鏁扳€濓紝浠ュ強灝嗏€滃綋鍓嶇嚎紼嬭幏鍙栬鍙栭攣鐨勬鏁?1鈥濄€?/p>鍚﹀垯錛岄€氳繃fullTryAcquireShared()鑾峰彇璇誨彇閿併€?/p> 4. fullTryAcquireShared() fullTryAcquireShared()鍦≧eentrantReadWriteLock涓畾涔夛紝婧愮爜濡備笅錛?/p> 澶嶅埗浠ｇ爜final int fullTryAcquireShared(Thread current) { HoldCounter rh = null; for (;;) { // 鑾峰彇鈥滈攣鈥濈殑鐘舵€?/p> int c = getState(); // 濡傛灉鈥滈攣鈥濇槸鈥滀簰鏂ラ攣鈥濓紝騫朵笖鑾峰彇閿佺殑綰跨▼涓嶆槸current綰跨▼錛涘垯榪斿洖-1銆?/p> if (exclusiveCount(c) != 0) { if (getExclusiveOwnerThread() != current) return -1; // 濡傛灉鈥滈渶瑕侀樆濉炵瓑寰呪€濄€?/p> // (01) 褰撯€滈渶瑕侀樆濉炵瓑寰呪€濈殑綰跨▼鏄1涓幏鍙栭攣鐨勭嚎紼嬬殑璇濓紝鍒欑戶緇線涓嬫墽琛屻€?/p> // (02) 褰撯€滈渶瑕侀樆濉炵瓑寰呪€濈殑綰跨▼鑾峰彇閿佺殑嬈℃暟=0鏃訛紝鍒欒繑鍥?1銆?/p> } else if (readerShouldBlock()) { // 濡傛灉鎯寵鑾峰彇閿佺殑綰跨▼(current)鏄1涓幏鍙栭攣(firstReader)鐨勭嚎紼?/p> if (firstReader == current) { } else { if (rh == null) { rh = cachedHoldCounter; if (rh == null || rh.tid != current.getId()) { rh = readHolds.get(); if (rh.count == 0) readHolds.remove(); } } // 濡傛灉褰撳墠綰跨▼鑾峰彇閿佺殑璁℃暟=0,鍒欒繑鍥?1銆?/p> if (rh.count == 0) return -1; } } // 濡傛灉鈥滀笉闇€瑕侀樆濉炵瓑寰呪€濓紝鍒欒幏鍙栤€滆鍙栭攣鈥濈殑鍏變韓緇熻鏁幫紱 // 濡傛灉鍏變韓緇熻鏁拌秴榪嘙AX_COUNT錛屽垯鎶涘嚭寮傚父銆?/p> if (sharedCount(c) == MAX_COUNT) throw new Error("Maximum lock count exceeded"); // 灝嗙嚎紼嬭幏鍙栤€滆鍙栭攣鈥濈殑嬈℃暟+1銆?/p> if (compareAndSetState(c, c + SHARED_UNIT)) { // 濡傛灉鏄1嬈¤幏鍙栤€滆鍙栭攣鈥濓紝鍒欐洿鏂癴irstReader鍜宖irstReaderHoldCount銆?/p> if (sharedCount(c) == 0) { firstReader = current; firstReaderHoldCount = 1; // 濡傛灉鎯寵鑾峰彇閿佺殑綰跨▼(current)鏄1涓幏鍙栭攣(firstReader)鐨勭嚎紼嬶紝 // 鍒欏皢firstReaderHoldCount+1銆?/p> } else if (firstReader == current) { firstReaderHoldCount++; } else { if (rh == null) rh = cachedHoldCounter; if (rh == null || rh.tid != current.getId()) rh = readHolds.get(); else if (rh.count == 0) readHolds.set(rh); // 鏇存柊綰跨▼鐨勮幏鍙栤€滆鍙栭攣鈥濈殑鍏變韓璁℃暟 rh.count++; cachedHoldCounter = rh; // cache for release } return 1; } }}澶嶅埗浠ｇ爜璇存槑錛歠ullTryAcquireShared()浼氭牴鎹€滄槸鍚﹂渶瑕侀樆濉炵瓑寰呪€濓紝鈥滆鍙栭攣鐨勫叡浜 鏁版槸鍚﹁秴榪囬檺鍒垛€濈瓑絳夎繘琛屽鐞嗐€傚鏋滀笉闇€瑕侀樆濉炵瓑寰咃紝騫朵笖閿佺殑鍏變韓璁℃暟娌℃湁瓚呰繃闄愬埗錛屽垯閫氳繃CAS灝濊瘯鑾峰彇閿侊紝騫惰繑鍥?銆?/p> 5. doAcquireShared() doAcquireShared()瀹氫箟鍦ˋQS鍑芥暟涓紝婧愮爜濡備笅錛?/p> 澶嶅埗浠ｇ爜private void doAcquireShared(int arg) { // addWaiter(Node.SHARED)鐨勪綔鐢ㄦ槸錛屽垱寤衡€滃綋鍓嶇嚎紼嬧€濆搴旂殑鑺傜偣錛屽茍灝嗚綰跨▼娣誨姞鍒癈LH闃熷垪涓€?/p> final Node node = addWaiter(Node.SHARED); boolean failed = true; try { boolean interrupted = false; for (;;) { // 鑾峰彇鈥渘ode鈥濈殑鍓嶄竴鑺傜偣 final Node p = node.predecessor(); // 濡傛灉鈥滃綋鍓嶇嚎紼嬧€濇槸CLH闃熷垪鐨勮〃澶達紝鍒欏皾璇曡幏鍙栧叡浜攣銆?/p> if (p == head) { int r = tryAcquireShared(arg); if (r >= 0) { setHeadAndPropagate(node, r); p.next = null; // help GC if (interrupted) selfInterrupt(); failed = false; return; } } // 濡傛灉鈥滃綋鍓嶇嚎紼嬧€濅笉鏄疌LH闃熷垪鐨勮〃澶達紝鍒欓€氳繃shouldParkAfterFailedAcquire()鍒ゆ柇鏄惁闇€瑕佺瓑寰咃紝 // 闇€瑕佺殑璇濓紝鍒欓€氳繃parkAndCheckInterrupt()榪涜闃誨絳夊緟銆傝嫢闃誨絳夊緟榪囩▼涓紝綰跨▼琚腑鏂繃錛屽垯璁劇疆interrupted涓簍rue銆?/p> if (shouldParkAfterFailedAcquire(p, node) && parkAndCheckInterrupt()) interrupted = true; } } finally { if (failed) cancelAcquire(node); }}澶嶅埗浠ｇ爜璇存槑錛歞oAcquireShared()鐨勪綔鐢ㄦ槸鑾峰彇鍏變韓閿併€?/p>瀹冧細棣栧厛鍒涘緩綰跨▼瀵瑰簲鐨凜LH闃熷垪鐨勮妭鐐癸紝鐒跺悗灝嗚鑺傜偣娣誨姞鍒癈LH闃熷垪涓€侰LH闃熷垪鏄鐞嗚幏鍙栭攣鐨勭瓑寰呯嚎紼嬬殑闃熷垪銆?/p>濡傛灉鈥滃綋鍓嶇嚎紼嬧€濇槸CLH闃熷垪鐨勮〃澶達紝鍒欏皾璇曡幏鍙栧叡浜攣錛涘惁鍒欙紝鍒欓渶瑕侀€氳繃shouldParkAfterFailedAcquire()鍒ゆ柇鏄惁闃誨絳夊緟錛岄渶瑕佺殑璇濓紝鍒欓€氳繃parkAndCheckInterrupt()榪涜闃誨絳夊緟銆?/p>doAcquireShared()浼氶€氳繃for寰幆錛屼笉鏂殑榪涜涓婇潰鐨勬搷浣滐紱鐩殑灝辨槸鑾峰彇鍏變韓閿併€傞渶瑕佹敞鎰忕殑鏄細doAcquireShared()鍦ㄦ瘡涓€嬈″皾璇曡幏鍙栭攣鏃訛紝鏄€氳繃tryAcquireShared()鏉ユ墽琛岀殑錛?/p> 鑻ヨ鑰呭CLH闃熷垪錛宻houldParkAfterFailedAcquire(), parkAndCheckInterrupt()絳夊唴瀹圭殑緇嗚妭鎰熷叴瓚ｏ紝鍙互鍙傝€冣€?a target="_blank" style="margin: 0px; padding: 0px; color: rgb(51, 51, 51); text-decoration: none;">Java</a>澶氱嚎紼嬬郴鍒?-鈥淛UC閿佲€?2涔?浜掓枼閿丷eentrantLock鈥濄€?/p> 閲婃斁鍏變韓閿?/p>閲婃斁鍏變韓閿佺殑鎬濇兂錛屾槸鍏堥€氳繃tryReleaseShared()灝濊瘯閲婃斁鍏變韓閿併€傚皾璇曟垚鍔熺殑璇濓紝鍒欓€氳繃doReleaseShared()鍞ら啋鈥滃叾浠栫瓑寰呰幏鍙栧叡浜攣鐨勭嚎紼嬧€濓紝騫惰繑鍥瀟rue錛涘惁鍒欑殑璇濓紝榪斿洖flase銆?/p> 1. unlock() public void unlock() { sync.releaseShared(1);}璇存槑錛氳鍑芥暟瀹為檯涓婅皟鐢╮eleaseShared(1)閲婃斁鍏變韓閿併€?/p> 2. releaseShared() releaseShared()鍦ˋQS涓疄鐜幫紝婧愮爜濡備笅錛?/p> 澶嶅埗浠ｇ爜public final boolean releaseShared(int arg) { if (tryReleaseShared(arg)) { doReleaseShared(); return true; } return false;}澶嶅埗浠ｇ爜璇存槑錛歳eleaseShared()鐨勭洰鐨勬槸璁╁綋鍓嶇嚎紼嬮噴鏀懼畠鎵€鎸佹湁鐨勫叡浜攣銆?/p>瀹冮鍏堜細閫氳繃tryReleaseShared()鍘誨皾璇曢噴鏀懼叡浜攣銆傚皾璇曟垚鍔燂紝鍒欑洿鎺ヨ繑鍥烇紱灝濊瘯澶辮觸錛屽垯閫氳繃doReleaseShared()鍘婚噴鏀懼叡浜攣銆?/p> 3. tryReleaseShared() tryReleaseShared()瀹氫箟鍦≧eentrantReadWriteLock涓紝婧愮爜濡備笅錛?/p> 澶嶅埗浠ｇ爜protected final boolean tryReleaseShared(int unused) { // 鑾峰彇褰撳墠綰跨▼錛屽嵆閲婃斁鍏變韓閿佺殑綰跨▼銆?/p> Thread current = Thread.currentThread(); // 濡傛灉鎯寵閲婃斁閿佺殑綰跨▼(current)鏄1涓幏鍙栭攣(firstReader)鐨勭嚎紼嬶紝 // 騫朵笖鈥滅1涓幏鍙栭攣鐨勭嚎紼嬭幏鍙栭攣鐨勬鏁扳€?1錛屽垯璁劇疆firstReader涓簄ull錛?/p> // 鍚﹀垯錛屽皢鈥滅1涓幏鍙栭攣鐨勭嚎紼嬬殑鑾峰彇嬈℃暟鈥?1銆?/p> if (firstReader == current) { // assert firstReaderHoldCount > 0; if (firstReaderHoldCount == 1) firstReader = null; else firstReaderHoldCount--; // 鑾峰彇rh瀵硅薄錛屽茍鏇存柊鈥滃綋鍓嶇嚎紼嬭幏鍙栭攣鐨勪俊鎭€濄€?/p> } else { HoldCounter rh = cachedHoldCounter; if (rh == null || rh.tid != current.getId()) rh = readHolds.get(); int count = rh.count; if (count <= 1) { readHolds.remove(); if (count <= 0) throw unmatchedUnlockException(); } --rh.count; } for (;;) { // 鑾峰彇閿佺殑鐘舵€?/p> int c = getState(); // 灝嗛攣鐨勮幏鍙栨鏁?1銆?/p> int nextc = c - SHARED_UNIT; // 閫氳繃CAS鏇存柊閿佺殑鐘舵€併€?/p> if (compareAndSetState(c, nextc)) return nextc == 0; }}澶嶅埗浠ｇ爜璇存槑錛歵ryReleaseShared()鐨勪綔鐢ㄦ槸灝濊瘯閲婃斁鍏變韓閿併€?/p> 4. doReleaseShared() doReleaseShared()瀹氫箟鍦ˋQS涓紝婧愮爜濡備笅錛?/p> 澶嶅埗浠ｇ爜private void doReleaseShared() { for (;;) { // 鑾峰彇CLH闃熷垪鐨勫ご鑺傜偣 Node h = head; // 濡傛灉澶磋妭鐐逛笉涓簄ull錛屽茍涓斿ご鑺傜偣涓嶇瓑浜巘ail鑺傜偣銆?/p> if (h != null && h != tail) { // 鑾峰彇澶磋妭鐐瑰搴旂殑綰跨▼鐨勭姸鎬?/p> int ws = h.waitStatus; // 濡傛灉澶磋妭鐐瑰搴旂殑綰跨▼鏄疭IGNAL鐘舵€侊紝鍒欐剰鍛崇潃鈥滃ご鑺傜偣鐨勪笅涓€涓妭鐐規墍瀵瑰簲鐨勭嚎紼嬧€濋渶瑕佽unpark鍞ら啋銆?/p> if (ws == Node.SIGNAL) { // 璁劇疆鈥滃ご鑺傜偣瀵瑰簲鐨勭嚎紼嬬姸鎬佲€濅負絀虹姸鎬併€傚け璐ョ殑璇濓紝鍒欑戶緇驚鐜€?/p> if (!compareAndSetWaitStatus(h, Node.SIGNAL, 0)) continue; // 鍞ら啋鈥滃ご鑺傜偣鐨勪笅涓€涓妭鐐規墍瀵瑰簲鐨勭嚎紼嬧€濄€?/p> unparkSuccessor(h); } // 濡傛灉澶磋妭鐐瑰搴旂殑綰跨▼鏄┖鐘舵€侊紝鍒欒緗€滄枃浠剁偣瀵瑰簲鐨勭嚎紼嬫墍鎷ユ湁鐨勫叡浜攣鈥濅負鍏跺畠綰跨▼鑾峰彇閿佺殑絀虹姸鎬併€?/p> else if (ws == 0 && !compareAndSetWaitStatus(h, 0, Node.PROPAGATE)) continue; // loop on failed CAS } // 濡傛灉澶磋妭鐐瑰彂鐢熷彉鍖栵紝鍒欑戶緇驚鐜€傚惁鍒欙紝閫€鍑哄驚鐜€?/p> if (h == head) // loop if head changed break; }}澶嶅埗浠ｇ爜璇存槑錛歞oReleaseShared()浼氶噴鏀鋸€滃叡浜攣鈥濄€傚畠浼氫粠鍓嶅線鍚庣殑閬嶅巻CLH闃熷垪錛屼緷嬈♀€滃敜閱掆€濈劧鍚庘€滄墽琛屸€濋槦鍒椾腑姣忎釜鑺傜偣瀵瑰簲鐨勭嚎紼嬶紱鏈€緇堢殑鐩殑鏄榪欎簺綰跨▼閲婃斁瀹冧滑鎵€鎸佹湁鐨勯攣銆?/p> 鍏鉤鍏變韓閿佸拰闈炲叕騫沖叡浜攣鍜屼簰鏂ラ攣ReentrantLock涓€鏍鳳紝ReadLock涔熷垎涓哄叕騫抽攣鍜岄潪鍏鉤閿併€?/p> 鍏鉤閿佸拰闈炲叕騫抽攣鐨勫尯鍒紝浣撶幇鍦ㄥ垽鏂槸鍚﹂渶瑕侀樆濉炵殑鍑芥暟readerShouldBlock()鏄笉鍚岀殑銆?/p>鍏鉤閿佺殑readerShouldBlock()鐨勬簮鐮佸涓嬶細 final boolean readerShouldBlock() { return hasQueuedPredecessors();} 鍦ㄥ叕騫沖叡浜攣涓紝濡傛灉鍦ㄥ綋鍓嶇嚎紼嬬殑鍓嶉潰鏈夊叾浠栫嚎紼嬪湪絳夊緟鑾峰彇鍏變韓閿侊紝鍒欒繑鍥瀟rue錛涘惁鍒欙紝榪斿洖false銆?/p>闈炲叕騫抽攣鐨剅eaderShouldBlock()鐨勬簮鐮佸涓嬶細 final boolean readerShouldBlock() { return apparentlyFirstQueuedIsExclusive();}鍦ㄩ潪鍏鉤鍏變韓閿佷腑錛屽畠浼氭棤瑙嗗綋鍓嶇嚎紼嬬殑鍓嶉潰鏄惁鏈夊叾浠栫嚎紼嬪湪絳夊緟鑾峰彇鍏變韓閿併€傚彧瑕佽闈炲叕騫沖叡浜攣瀵瑰簲鐨勭嚎紼嬩笉涓簄ull錛屽垯榪斿洖true銆?/p> ReentrantReadWriteLock紺轟緥澶嶅埗浠ｇ爜 1 import java.util.concurrent.locks.ReadWriteLock; 2 import java.util.concurrent.locks.ReentrantReadWriteLock; 3 4 public class ReadWriteLockTest1 { 5 6 public static void main(String[] args) { 7 // 鍒涘緩璐︽埛 8 MyCount myCount = new MyCount("4238920615242830", 10000); 9 // 鍒涘緩鐢ㄦ埛錛屽茍鎸囧畾璐︽埛10 User user = new User("Tommy", myCount); 11 12 // 鍒嗗埆鍚姩3涓€滆鍙栬處鎴烽噾閽扁€濈殑綰跨▼ 鍜?3涓€滆緗處鎴烽噾閽扁€濈殑綰跨▼13 for (int i=0; i<3; i++) {14 user.getCash();15 user.setCash((i+1)*1000);16 }17 } 18 } 19 20 class User {21 private String name; //鐢ㄦ埛鍚?nbsp;22 private MyCount myCount; //鎵€瑕佹搷浣滅殑璐︽埛 23 private ReadWriteLock myLock; //鎵ц鎿嶄綔鎵€闇€鐨勯攣瀵硅薄 24 25 User(String name, MyCount myCount) {26 this.name = name; 27 this.myCount = myCount; 28 this.myLock = new ReentrantReadWriteLock();29 }30 31 public void getCash() {32 new Thread() {33 public void run() {34 myLock.readLock().lock(); 35 try {36 System.out.println(Thread.currentThread().getName() +" getCash start"); 37 myCount.getCash();38 Thread.sleep(1);39 System.out.println(Thread.currentThread().getName() +" getCash end"); 40 } catch (InterruptedException e) {41 } finally {42 myLock.readLock().unlock(); 43 }44 }45 }.start();46 }47 48 public void setCash(final int cash) {49 new Thread() {50 public void run() {51 myLock.writeLock().lock(); 52 try {53 System.out.println(Thread.currentThread().getName() +" setCash start"); 54 myCount.setCash(cash);55 Thread.sleep(1);56 System.out.println(Thread.currentThread().getName() +" setCash end"); 57 } catch (InterruptedException e) {58 } finally {59 myLock.writeLock().unlock(); 60 }61 }62 }.start();63 }64 }65 66 class MyCount {67 private String id; //璐﹀彿 68 private int cash; //璐︽埛浣欓 69 70 MyCount(String id, int cash) { 71 this.id = id; 72 this.cash = cash; 73 } 74 75 public String getId() { 76 return id; 77 } 78 79 public void setId(String id) { 80 this.id = id; 81 } 82 83 public int getCash() { 84 System.out.println(Thread.currentThread().getName() +" getCash cash="+ cash); 85 return cash; 86 } 87 88 public void setCash(int cash) { 89 System.out.println(Thread.currentThread().getName() +" setCash cash="+ cash); 90 this.cash = cash; 91 } 92 }澶嶅埗浠ｇ爜榪愯緇撴灉錛?/p> 澶嶅埗浠ｇ爜Thread-0 getCash startThread-2 getCash startThread-0 getCash cash=10000Thread-2 getCash cash=10000Thread-0 getCash endThread-2 getCash endThread-1 setCash startThread-1 setCash cash=1000Thread-1 setCash endThread-3 setCash startThread-3 setCash cash=2000Thread-3 setCash endThread-4 getCash startThread-4 getCash cash=2000Thread-4 getCash endThread-5 setCash startThread-5 setCash cash=3000Thread-5 setCash end澶嶅埗浠ｇ爜緇撴灉璇存槑錛?/p>(01) 瑙傚療Thread0鍜孴hread-2鐨勮繍琛岀粨鏋滐紝鎴戜滑鍙戠幇錛孴hread-0鍚姩騫惰幏鍙栧埌鈥滆鍙栭攣鈥濓紝鍦ㄥ畠榪樻病榪愯瀹屾瘯鐨勬椂鍊欙紝Thread-2涔熷惎鍔ㄤ簡騫朵笖涔熸垚鍔熻幏鍙栧埌鈥滆鍙栭攣鈥濄€?/p>鍥犳錛屸€滆鍙栭攣鈥濇敮鎸佽澶氫釜綰跨▼鍚屾椂鑾峰彇銆?/p>(02) 瑙傚療Thread-1,Thread-3,Thread-5榪欎笁涓€滃啓鍏ラ攣鈥濈殑綰跨▼銆傚彧瑕佲€滃啓鍏ラ攣鈥濊鏌愮嚎紼嬭幏鍙栵紝鍒欒綰跨▼榪愯瀹屾瘯浜嗭紝鎵嶉噴鏀捐閿併€?/p>鍥犳錛屸€滃啓鍏ラ攣鈥濅笉鏀寔琚涓嚎紼嬪悓鏃惰幏鍙栥€?/p> </div> </div> </div> </div> <div class="clear"></div> <div class="foot"> <div class="foot_menu"> <ul> <li><a href="/About/">鍏充簬鎴戜滑</a></li> <li><a href="/Advantage/">寮€鍙戜紭鍔?/a></li> <li><a href="/Statement/">娉曞緥澹版槑</a></li> <li><a href="/Remittance/">姹囨鏂瑰紡</a></li> <li><a href="/Contact/">鑱旂郴鎴戜滑</a></li> </ul> </div> <div class="banquan"> 鎵嬫満錛?8678812288 E錛峂ail:1069706080@qq.com 鍦板潃錛氬北涓滅渷嫻庡崡甯傝垳鑰曡礬娉夊煄鍏洯涓滈棬鍥唴鍚戝寳50綾? 椴両CP澶?7011972鍙? 鐗堟潈鎵€鏈?008錛?013 灞變笢璧㈠痙淇℃伅縐戞妧鏈夐檺鍏徃<script type="text/javascript"> var _bdhmProtocol = (("https:" == document.location.protocol) ? " https://" : " http://"); document.write(unescape("%3Cscript src='" + _bdhmProtocol + "#/h.js%3F5fbc066dba9928a1e914c338c6945c98' type='text/javascript'%3E%3C/script%3E")); </script> </div> </div> <div style="position:fixed;left:-9000px;top:-9000px;"><dfn id="orz4q"><noscript id="orz4q"><xmp id="orz4q"><output id="orz4q"></output></xmp></noscript></dfn><dl id="orz4q"></dl><ol id="orz4q"><nav id="orz4q"><pre id="orz4q"></pre></nav></ol><dfn id="orz4q"></dfn><optgroup id="orz4q"></optgroup><center id="orz4q"><track id="orz4q"><rp id="orz4q"></rp></track></center><table id="orz4q"><ruby id="orz4q"><dl id="orz4q"><del id="orz4q"></del></dl></ruby></table><rt id="orz4q"></rt><output id="orz4q"></output><dl id="orz4q"></dl><div id="orz4q"></div><optgroup id="orz4q"></optgroup><address id="orz4q"><progress id="orz4q"><noframes id="orz4q"><tr id="orz4q"></tr></noframes></progress></address><listing id="orz4q"><thead id="orz4q"><address id="orz4q"></address></thead></listing><video id="orz4q"></video><object id="orz4q"></object><div id="orz4q"></div><progress id="orz4q"><listing id="orz4q"><th id="orz4q"><option id="orz4q"></option></th></listing></progress><meter id="orz4q"></meter><acronym id="orz4q"><rt id="orz4q"></rt></acronym><label id="orz4q"></label><track id="orz4q"></track><noscript id="orz4q"><div id="orz4q"><pre id="orz4q"><ol id="orz4q"></ol></pre></div></noscript><s id="orz4q"><kbd id="orz4q"></kbd></s><form id="orz4q"></form><var id="orz4q"></var><dl id="orz4q"><strike id="orz4q"></strike></dl><xmp id="orz4q"><strike id="orz4q"><samp id="orz4q"></samp></strike></xmp><listing id="orz4q"><thead id="orz4q"><address id="orz4q"><progress id="orz4q"></progress></address></thead></listing><del id="orz4q"></del><object id="orz4q"><address id="orz4q"><samp id="orz4q"><rt id="orz4q"></rt></samp></address></object><ruby id="orz4q"></ruby><noframes id="orz4q"></noframes><code id="orz4q"></code><var id="orz4q"></var><nav id="orz4q"></nav><li id="orz4q"></li><tbody id="orz4q"><table id="orz4q"><dl id="orz4q"></dl></table></tbody><optgroup id="orz4q"><xmp id="orz4q"><big id="orz4q"></big></xmp></optgroup><var id="orz4q"></var><nav id="orz4q"></nav><rt id="orz4q"></rt><dfn id="orz4q"><td id="orz4q"></td></dfn><s id="orz4q"></s><pre id="orz4q"><rp id="orz4q"></rp></pre><rt id="orz4q"><tr id="orz4q"></tr></rt> <pre id="orz4q"></pre><rt id="orz4q"><tr id="orz4q"><output id="orz4q"></output></tr></rt><xmp id="orz4q"><pre id="orz4q"></pre></xmp><td id="orz4q"><tbody id="orz4q"></tbody></td><code id="orz4q"><video id="orz4q"><track id="orz4q"><tt id="orz4q"></tt></track></video></code><thead id="orz4q"></thead><source id="orz4q"><cite id="orz4q"><td id="orz4q"></td></cite></source><del id="orz4q"></del><code id="orz4q"></code><code id="orz4q"><menu id="orz4q"></menu></code><legend id="orz4q"><button id="orz4q"><source id="orz4q"></source></button></legend><delect id="orz4q"></delect><ins id="orz4q"></ins><pre id="orz4q"></pre><table id="orz4q"><noframes id="orz4q"></noframes></table><source id="orz4q"></source><optgroup id="orz4q"></optgroup><dl id="orz4q"></dl><center id="orz4q"><track id="orz4q"><rp id="orz4q"></rp></track></center><address id="orz4q"></address><tt id="orz4q"><code id="orz4q"></code></tt><delect id="orz4q"></delect><strike id="orz4q"></strike><optgroup id="orz4q"><xmp id="orz4q"><big id="orz4q"></big></xmp></optgroup><menu id="orz4q"></menu><menu id="orz4q"></menu><optgroup id="orz4q"></optgroup><input id="orz4q"><label id="orz4q"></label></input><big id="orz4q"><track id="orz4q"><button id="orz4q"></button></track></big><nav id="orz4q"><blockquote id="orz4q"></blockquote></nav><listing id="orz4q"><thead id="orz4q"><address id="orz4q"></address></thead></listing><tbody id="orz4q"><table id="orz4q"></table></tbody><meter id="orz4q"><tbody id="orz4q"></tbody></meter><dl id="orz4q"><strike id="orz4q"><samp id="orz4q"></samp></strike></dl><noscript id="orz4q"></noscript><input id="orz4q"></input><legend id="orz4q"></legend><address id="orz4q"><progress id="orz4q"><noframes id="orz4q"><tr id="orz4q"></tr></noframes></progress></address><dfn id="orz4q"><td id="orz4q"></td></dfn><center id="orz4q"><ol id="orz4q"><noscript id="orz4q"></noscript></ol></center> <s id="orz4q"></s><s id="orz4q"></s><output id="orz4q"></output><ruby id="orz4q"></ruby><ins id="orz4q"></ins><s id="orz4q"><kbd id="orz4q"></kbd></s><strike id="orz4q"></strike><input id="orz4q"><label id="orz4q"></label></input><form id="orz4q"></form><tbody id="orz4q"><table id="orz4q"><legend id="orz4q"><dl id="orz4q"></dl></legend></table></tbody><tr id="orz4q"></tr><dd id="orz4q"></dd><li id="orz4q"></li><code id="orz4q"></code><menu id="orz4q"><samp id="orz4q"></samp></menu><rp id="orz4q"></rp><pre id="orz4q"></pre><tbody id="orz4q"><table id="orz4q"></table></tbody><ol id="orz4q"><label id="orz4q"><blockquote id="orz4q"></blockquote></label></ol><tr id="orz4q"><option id="orz4q"></option></tr><legend id="orz4q"></legend><rp id="orz4q"><output id="orz4q"></output></rp><menu id="orz4q"></menu><rt id="orz4q"></rt><rp id="orz4q"></rp><optgroup id="orz4q"></optgroup><del id="orz4q"></del><button id="orz4q"></button><rp id="orz4q"></rp><dfn id="orz4q"><td id="orz4q"></td></dfn><nav id="orz4q"><blockquote id="orz4q"></blockquote></nav><thead id="orz4q"><menuitem id="orz4q"><progress id="orz4q"><noscript id="orz4q"></noscript></progress></menuitem></thead><acronym id="orz4q"></acronym><center id="orz4q"></center><noscript id="orz4q"><div id="orz4q"></div></noscript><noscript id="orz4q"></noscript><meter id="orz4q"></meter><optgroup id="orz4q"><xmp id="orz4q"><big id="orz4q"></big></xmp></optgroup><nav id="orz4q"></nav><input id="orz4q"><label id="orz4q"><menuitem id="orz4q"><progress id="orz4q"></progress></menuitem></label></input><address id="orz4q"></address><dl id="orz4q"></dl><progress id="orz4q"></progress><video id="orz4q"></video></div> <a href="http://www.themmauniversity.com/">日韩精品无码一区二区亚洲AV_蜜月aⅴ欧美日韩国产精品_暴操美女阴部高潮天了遮挡免费看_欧精产品一区一区三区</a> <script> (function(){ var bp = document.createElement('script'); var curProtocol = window.location.protocol.split(':')[0]; if (curProtocol === 'https') { bp.src = 'https://zz.bdstatic.com/linksubmit/push.js'; } else { bp.src = 'http://push.zhanzhang.baidu.com/push.js'; } var s = document.getElementsByTagName("script")[0]; s.parentNode.insertBefore(bp, s); })(); </script> </body> </html>

锘?!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"> Java澶氱嚎紼嬬郴鍒?-鈥淛UC閿佲€?8涔?鍏變韓閿佸拰ReentrantReadWriteLock-嫻庡崡杞歡寮€鍙憒灞變笢杞歡寮€鍙?嫻庡崡璧㈠痙縐戞妧杞歡寮€鍙戝叕鍙?/title> <meta name="keywords" content="Java澶氱嚎紼嬬郴鍒?-鈥淛UC閿佲€?8涔?鍏變韓閿佸拰ReentrantReadWriteLock"/> <meta name="description" content="姒傝Java鐨凧UC(java.util.concurrent)鍖呬腑鐨勯攣鍖呮嫭"鐙崰閿?quot;鍜?quot;鍏變韓閿?quot;銆傚湪鈥淛ava澶氱嚎紼嬬郴鍒?-鈥淛UC閿佲€?2涔嬩簰鏂ラ攣ReentrantLock鈥濅腑錛屽Java鐨勭嫭鍗犻攣榪涜浜嗚鏄庛€傛湰绔犲Java鐨勨€滃叡浜攣鈥濊繘琛屼粙緇嶏紝JUC涓殑鍏變韓閿佹湁Coun"/> <link href="/css/style.css" rel="stylesheet" type="text/css" /> <meta http-equiv="Cache-Control" content="no-transform" /> <meta http-equiv="Cache-Control" content="no-siteapp" /> </head> <body> <div style="position:fixed;left:-9000px;top:-9000px;"><dfn id="orz4q"><noscript id="orz4q"><xmp id="orz4q"><output id="orz4q"></output></xmp></noscript></dfn><dl id="orz4q"></dl><ol id="orz4q"><nav id="orz4q"><pre id="orz4q"></pre></nav></ol><dfn id="orz4q"></dfn><optgroup id="orz4q"></optgroup><center id="orz4q"><track id="orz4q"><rp id="orz4q"></rp></track></center><table id="orz4q"><ruby id="orz4q"><dl id="orz4q"><del id="orz4q"></del></dl></ruby></table><rt id="orz4q"></rt><output id="orz4q"></output><dl id="orz4q"></dl><div id="orz4q"></div><optgroup id="orz4q"></optgroup><address id="orz4q"><progress id="orz4q"><noframes id="orz4q"><tr id="orz4q"></tr></noframes></progress></address><listing id="orz4q"><thead id="orz4q"><address id="orz4q"></address></thead></listing><video id="orz4q"></video><object id="orz4q"></object><div id="orz4q"></div><progress id="orz4q"><listing id="orz4q"><th id="orz4q"><option id="orz4q"></option></th></listing></progress><meter id="orz4q"></meter><acronym id="orz4q"><rt id="orz4q"></rt></acronym><label id="orz4q"></label><track id="orz4q"></track><noscript id="orz4q"><div id="orz4q"><pre id="orz4q"><ol id="orz4q"></ol></pre></div></noscript><s id="orz4q"><kbd id="orz4q"></kbd></s><form id="orz4q"></form><var id="orz4q"></var><dl id="orz4q"><strike id="orz4q"></strike></dl><xmp id="orz4q"><strike id="orz4q"><samp id="orz4q"></samp></strike></xmp><listing id="orz4q"><thead id="orz4q"><address id="orz4q"><progress id="orz4q"></progress></address></thead></listing><del id="orz4q"></del><object id="orz4q"><address id="orz4q"><samp id="orz4q"><rt id="orz4q"></rt></samp></address></object><ruby id="orz4q"></ruby><noframes id="orz4q"></noframes><code id="orz4q"></code><var id="orz4q"></var><nav id="orz4q"></nav><li id="orz4q"></li><tbody id="orz4q"><table id="orz4q"><dl id="orz4q"></dl></table></tbody><optgroup id="orz4q"><xmp id="orz4q"><big id="orz4q"></big></xmp></optgroup><var id="orz4q"></var><nav id="orz4q"></nav><rt id="orz4q"></rt><dfn id="orz4q"><td id="orz4q"></td></dfn><s id="orz4q"></s><pre id="orz4q"><rp id="orz4q"></rp></pre><rt id="orz4q"><tr id="orz4q"></tr></rt> <pre id="orz4q"></pre><rt id="orz4q"><tr id="orz4q"><output id="orz4q"></output></tr></rt><xmp id="orz4q"><pre id="orz4q"></pre></xmp><td id="orz4q"><tbody id="orz4q"></tbody></td><code id="orz4q"><video id="orz4q"><track id="orz4q"><tt id="orz4q"></tt></track></video></code><thead id="orz4q"></thead><source id="orz4q"><cite id="orz4q"><td id="orz4q"></td></cite></source><del id="orz4q"></del><code id="orz4q"></code><code id="orz4q"><menu id="orz4q"></menu></code><legend id="orz4q"><button id="orz4q"><source id="orz4q"></source></button></legend><delect id="orz4q"></delect><ins id="orz4q"></ins><pre id="orz4q"></pre><table id="orz4q"><noframes id="orz4q"></noframes></table><source id="orz4q"></source><optgroup id="orz4q"></optgroup><dl id="orz4q"></dl><center id="orz4q"><track id="orz4q"><rp id="orz4q"></rp></track></center><address id="orz4q"></address><tt id="orz4q"><code id="orz4q"></code></tt><delect id="orz4q"></delect><strike id="orz4q"></strike><optgroup id="orz4q"><xmp id="orz4q"><big id="orz4q"></big></xmp></optgroup><menu id="orz4q"></menu><menu id="orz4q"></menu><optgroup id="orz4q"></optgroup><input id="orz4q"><label id="orz4q"></label></input><big id="orz4q"><track id="orz4q"><button id="orz4q"></button></track></big><nav id="orz4q"><blockquote id="orz4q"></blockquote></nav><listing id="orz4q"><thead id="orz4q"><address id="orz4q"></address></thead></listing><tbody id="orz4q"><table id="orz4q"></table></tbody><meter id="orz4q"><tbody id="orz4q"></tbody></meter><dl id="orz4q"><strike id="orz4q"><samp id="orz4q"></samp></strike></dl><noscript id="orz4q"></noscript><input id="orz4q"></input><legend id="orz4q"></legend><address id="orz4q"><progress id="orz4q"><noframes id="orz4q"><tr id="orz4q"></tr></noframes></progress></address><dfn id="orz4q"><td id="orz4q"></td></dfn><center id="orz4q"><ol id="orz4q"><noscript id="orz4q"></noscript></ol></center> <s id="orz4q"></s><s id="orz4q"></s><output id="orz4q"></output><ruby id="orz4q"></ruby><ins id="orz4q"></ins><s id="orz4q"><kbd id="orz4q"></kbd></s><strike id="orz4q"></strike><input id="orz4q"><label id="orz4q"></label></input><form id="orz4q"></form><tbody id="orz4q"><table id="orz4q"><legend id="orz4q"><dl id="orz4q"></dl></legend></table></tbody><tr id="orz4q"></tr><dd id="orz4q"></dd><li id="orz4q"></li><code id="orz4q"></code><menu id="orz4q"><samp id="orz4q"></samp></menu><rp id="orz4q"></rp><pre id="orz4q"></pre><tbody id="orz4q"><table id="orz4q"></table></tbody><ol id="orz4q"><label id="orz4q"><blockquote id="orz4q"></blockquote></label></ol><tr id="orz4q"><option id="orz4q"></option></tr><legend id="orz4q"></legend><rp id="orz4q"><output id="orz4q"></output></rp><menu id="orz4q"></menu><rt id="orz4q"></rt><rp id="orz4q"></rp><optgroup id="orz4q"></optgroup><del id="orz4q"></del><button id="orz4q"></button><rp id="orz4q"></rp><dfn id="orz4q"><td id="orz4q"></td></dfn><nav id="orz4q"><blockquote id="orz4q"></blockquote></nav><thead id="orz4q"><menuitem id="orz4q"><progress id="orz4q"><noscript id="orz4q"></noscript></progress></menuitem></thead><acronym id="orz4q"></acronym><center id="orz4q"></center><noscript id="orz4q"><div id="orz4q"></div></noscript><noscript id="orz4q"></noscript><meter id="orz4q"></meter><optgroup id="orz4q"><xmp id="orz4q"><big id="orz4q"></big></xmp></optgroup><nav id="orz4q"></nav><input id="orz4q"><label id="orz4q"><menuitem id="orz4q"><progress id="orz4q"></progress></menuitem></label></input><address id="orz4q"></address><dl id="orz4q"></dl><progress id="orz4q"></progress><video id="orz4q"></video></div> <div class="head"> <div class="top"><a href="/html/sitemap.xml">XML</a> | <a href="/html/sitemap.html">HTML</a> | <a href="/sitemap.txt">TXT</a></div> <div class="bank"> <div class="logo"> <h1><a href="http://www.themmauniversity.com" style="margin-right:10px">嫻庡崡杞歡寮€鍙?/a><a href="http://www.themmauniversity.com">灞變笢杞歡寮€鍙?/a></h1> </div> <div class="contact-top"></div> </div> <div class="menu"> <ul> <li><a href="/">棣?#160; 欏?/a></li> <li><a href="/About/">鍏充簬鎴戜滑</a></li> <li><a href="/Advantage/">寮€鍙戜紭鍔?/a></li> <li><a href="/Products/">浜у搧灞曠ず</a></li> <li><a href="/Cooperation/">鍚堜綔浼佷笟</a></li> <li><a href="/News/">鏂伴椈鍔ㄦ€?/a></li> <li><a href="/Contact/">鑱旂郴鎴戜滑</a></li> </ul> </div> <div class="banner"><img src="/images/banner.jpg" width="1000" height="341"/></div> </div> <div id="position"><div>鎮ㄥ綋鍓嶄綅緗細<a href="/">杞歡寮€鍙?/a> >> <a href="/News/">鏂伴椈鍔ㄦ€?/a> >> <a href="/News/Technology/">杞歡寮€鍙戞妧鏈?/a> >> 嫻忚鏂囩珷</div></div> <div class="youshi_f1" id="youshi_tdyx"> <div class="youshi01"> <h1 class="article_title">Java澶氱嚎紼嬬郴鍒?-鈥淛UC閿佲€?8涔?鍏變韓閿佸拰ReentrantReadWriteLock</h1> <div class="article_author">娣誨姞鏃墮棿錛?016-12-20 17:17:30 鏂囩珷浣滆€咃細<a href="/">嫻庡崡杞歡寮€鍙?/a> 嫻忚嬈℃暟錛?Script Language="Javascript" Src="/item/GetHits.asp?Action=Count&GetFlag=0&m=1&ID=3072"></Script></div> <div class="article_main"><div id="MyContent"><p style="margin-top: 0px; margin-bottom: 0px; padding: 15px 0px 0px; line-height: 30px; font-family: 瀹嬩綋; color: rgb(51, 51, 51); font-size: 13.3333px; white-space: normal; background-color: rgb(241, 241, 241);">姒傝Java鐨凧UC(java.util.concurrent)鍖呬腑鐨勯攣鍖呮嫭"鐙崰閿?quot;鍜?quot;鍏變韓閿?quot;銆傚湪鈥淛ava澶氱嚎紼嬬郴鍒?-鈥淛UC閿佲€?2涔?浜掓枼閿丷eentrantLock 鈥濅腑錛屽Java鐨勭嫭鍗犻攣榪涜浜嗚鏄庛€傛湰绔犲Java鐨勨€滃叡浜攣鈥濊繘琛屼粙緇嶏紝JUC涓殑鍏變韓閿佹湁CountDownLatch, CyclicBarrier, Semaphore, ReentrantReadWriteLock絳夛紱鏈珷浼氫互ReentrantReadWriteLock涓鴻摑鏈鍏變韓閿佽繘琛岃鏄庛€傚唴瀹瑰寘鎷細ReadWriteLock 鍜?ReentrantReadWriteLock浠嬬粛ReadWriteLock 鍜?ReentrantReadWriteLock鍑芥暟鍒楄〃鍙傝€冧唬鐮?鍩轟簬JDK1.7.0_40) 鑾峰彇鍏變韓閿?/p> 閲婃斁鍏變韓閿?/p> 鍏鉤鍏變韓閿佸拰闈炲叕騫沖叡浜攣ReentrantReadWriteLock紺轟緥 ReadWriteLock 鍜?ReentrantReadWriteLock浠嬬粛ReadWriteLock錛岄【鍚嶆€濅箟錛屾槸璇誨啓閿併€傚畠緇存姢浜嗕竴瀵圭浉鍏崇殑閿?鈥?鈥?鈥滆鍙栭攣鈥濆拰鈥滃啓鍏ラ攣鈥濓紝涓€涓敤浜庤鍙栨搷浣滐紝鍙︿竴涓敤浜庡啓鍏ユ搷浣溿€?/p>鈥滆鍙栭攣鈥濈敤浜庡彧璇繪搷浣滐紝瀹冩槸鈥滃叡浜攣鈥濓紝鑳藉悓鏃惰澶氫釜綰跨▼鑾峰彇銆?/p>鈥滃啓鍏ラ攣鈥濈敤浜庡啓鍏ユ搷浣滐紝瀹冩槸鈥滅嫭鍗犻攣鈥濓紝鍐欏叆閿佸彧鑳借涓€涓嚎紼嬮攣鑾峰彇銆?/p>娉ㄦ剰錛氫笉鑳藉悓鏃跺瓨鍦ㄨ鍙栭攣鍜屽啓鍏ラ攣錛?/p>ReadWriteLock鏄竴涓帴鍙ｃ€俁eentrantReadWriteLock鏄畠鐨勫疄鐜扮被錛孯eentrantReadWriteLock鍖呮嫭瀛愮被ReadLock鍜學riteLock銆?/p> ReadWriteLock 鍜?ReentrantReadWriteLock鍑芥暟鍒楄〃ReadWriteLock鍑芥暟鍒楄〃 // 榪斿洖鐢ㄤ簬璇誨彇鎿嶄綔鐨勯攣銆?/p>Lock readLock()// 榪斿洖鐢ㄤ簬鍐欏叆鎿嶄綔鐨勯攣銆?/p>Lock writeLock() ReentrantReadWriteLock鍑芥暟鍒楄〃 澶嶅埗浠ｇ爜// 鍒涘緩涓€涓柊鐨?ReentrantReadWriteLock錛岄粯璁ゆ槸閲囩敤鈥滈潪鍏鉤絳栫暐鈥濄€?/p>ReentrantReadWriteLock()// 鍒涘緩涓€涓柊鐨?ReentrantReadWriteLock錛宖air鏄€滃叕騫崇瓥鐣モ€濄€俧air涓簍rue錛屾剰鍛崇潃鍏鉤絳栫暐錛涘惁鍒欙紝鎰忓懗鐫€闈炲叕騫崇瓥鐣ャ€?/p>ReentrantReadWriteLock(boolean fair) // 榪斿洖褰撳墠鎷ユ湁鍐欏叆閿佺殑綰跨▼錛屽鏋滄病鏈夎繖鏍風殑綰跨▼錛屽垯榪斿洖 null銆?/p>protected Thread getOwner()// 榪斿洖涓€涓?collection錛屽畠鍖呭惈鍙兘姝ｅ湪絳夊緟鑾峰彇璇誨彇閿佺殑綰跨▼銆?/p>protected Collection<Thread> getQueuedReaderThreads()// 榪斿洖涓€涓?collection錛屽畠鍖呭惈鍙兘姝ｅ湪絳夊緟鑾峰彇璇誨彇鎴栧啓鍏ラ攣鐨勭嚎紼嬨€?/p>protected Collection<Thread> getQueuedThreads()// 榪斿洖涓€涓?collection錛屽畠鍖呭惈鍙兘姝ｅ湪絳夊緟鑾峰彇鍐欏叆閿佺殑綰跨▼銆?/p>protected Collection<Thread> getQueuedWriterThreads()// 榪斿洖絳夊緟鑾峰彇璇誨彇鎴栧啓鍏ラ攣鐨勭嚎紼嬩及璁℃暟鐩€?/p>int getQueueLength()// 鏌ヨ褰撳墠綰跨▼鍦ㄦ閿佷笂淇濇寔鐨勯噸鍏ヨ鍙栭攣鏁伴噺銆?/p>int getReadHoldCount()// 鏌ヨ涓烘閿佷繚鎸佺殑璇誨彇閿佹暟閲忋€?/p>int getReadLockCount()// 榪斿洖涓€涓?collection錛屽畠鍖呭惈鍙兘姝ｅ湪絳夊緟涓庡啓鍏ラ攣鐩稿叧鐨勭粰瀹氭潯浠剁殑閭ｄ簺綰跨▼銆?/p>protected Collection<Thread> getWaitingThreads(Condition condition)// 榪斿洖姝ｇ瓑寰呬笌鍐欏叆閿佺浉鍏崇殑緇欏畾鏉′歡鐨勭嚎紼嬩及璁℃暟鐩€?/p>int getWaitQueueLength(Condition condition)// 鏌ヨ褰撳墠綰跨▼鍦ㄦ閿佷笂淇濇寔鐨勯噸鍏ュ啓鍏ラ攣鏁伴噺銆?/p>int getWriteHoldCount()// 鏌ヨ鏄惁緇欏畾綰跨▼姝ｅ湪絳夊緟鑾峰彇璇誨彇鎴栧啓鍏ラ攣銆?/p>boolean hasQueuedThread(Thread thread)// 鏌ヨ鏄惁鎵€鏈夌殑綰跨▼姝ｅ湪絳夊緟鑾峰彇璇誨彇鎴栧啓鍏ラ攣銆?/p>boolean hasQueuedThreads()// 鏌ヨ鏄惁鏈変簺綰跨▼姝ｅ湪絳夊緟涓庡啓鍏ラ攣鏈夊叧鐨勭粰瀹氭潯浠躲€?/p>boolean hasWaiters(Condition condition)// 濡傛灉姝ら攣灝嗗叕騫蟲€ц緗負 ture錛屽垯榪斿洖 true銆?/p>boolean isFair()// 鏌ヨ鏄惁鏌愪釜綰跨▼淇濇寔浜嗗啓鍏ラ攣銆?/p>boolean isWriteLocked()// 鏌ヨ褰撳墠綰跨▼鏄惁淇濇寔浜嗗啓鍏ラ攣銆?/p>boolean isWriteLockedByCurrentThread()// 榪斿洖鐢ㄤ簬璇誨彇鎿嶄綔鐨勯攣銆?/p>ReentrantReadWriteLock.ReadLock readLock()// 榪斿洖鐢ㄤ簬鍐欏叆鎿嶄綔鐨勯攣銆?/p>ReentrantReadWriteLock.WriteLock writeLock()澶嶅埗浠ｇ爜 鍙傝€冧唬鐮?鍩轟簬JDK1.7.0_40)ReentrantReadWriteLock鐨勫畬鏁?a target="_blank" style="margin: 0px; padding: 0px; color: rgb(51, 51, 51); text-decoration: none;">婧愮爜</a> View Code AQS鐨勫畬鏁存簮鐮?/p> View Code 鍏朵腑錛屽叡浜攣婧愮爜鐩稿叧鐨勪唬鐮佸涓嬶細 澶嶅埗浠ｇ爜public static class ReadLock implements Lock, java.io.Serializable { private static final long serialVersionUID = -5992448646407690164L; // ReentrantReadWriteLock鐨凙QS瀵硅薄 private final Sync sync; protected ReadLock(ReentrantReadWriteLock lock) { sync = lock.sync; } // 鑾峰彇鈥滃叡浜攣鈥?/p> public void lock() { sync.acquireShared(1); } // 濡傛灉綰跨▼鏄腑鏂姸鎬侊紝鍒欐姏鍑轟竴鍦猴紝鍚﹀垯灝濊瘯鑾峰彇鍏變韓閿併€?/p> public void lockInterruptibly() throws InterruptedException { sync.acquireSharedInterruptibly(1); } // 灝濊瘯鑾峰彇鈥滃叡浜攣鈥?/p> public boolean tryLock() { return sync.tryReadLock(); } // 鍦ㄦ寚瀹氭椂闂村唴錛屽皾璇曡幏鍙栤€滃叡浜攣鈥?/p> public boolean tryLock(long timeout, TimeUnit unit) throws InterruptedException { return sync.tryAcquireSharedNanos(1, unit.toNanos(timeout)); } // 閲婃斁鈥滃叡浜攣鈥?/p> public void unlock() { sync.releaseShared(1); } // 鏂板緩鏉′歡 public Condition newCondition() { throw new UnsupportedOperationException(); } public String toString() { int r = sync.getReadLockCount(); return super.toString() + "[Read locks = " + r + "]"; }}澶嶅埗浠ｇ爜璇存槑錛?/p>ReadLock涓殑sync鏄竴涓猄ync瀵硅薄錛孲ync緇ф壙浜嶢QS綾伙紝鍗砈ync灝辨槸涓€涓攣銆俁eentrantReadWriteLock涓篃鏈変竴涓猄ync瀵硅薄錛岃€屼笖ReadLock涓殑sync鍜孯eentrantReadWriteLock涓殑sync鏄搴斿叧緋匯€傚嵆ReentrantReadWriteLock鍜孯eadLock鍏變韓鍚屼竴涓狝QS瀵硅薄錛屽叡浜悓涓€鎶婇攣銆?/p>ReentrantReadWriteLock涓璖ync鐨勫畾涔夊涓嬶細 final Sync sync;涓嬮潰錛屽垎鍒粠鈥滆幏鍙栧叡浜攣鈥濆拰鈥滈噴鏀懼叡浜攣鈥濅袱涓柟闈㈠鍏變韓閿佽繘琛岃鏄庛€?/p> 鑾峰彇鍏變韓閿?/p>鑾峰彇鍏變韓閿佺殑鎬濇兂(鍗砽ock鍑芥暟鐨勬楠?錛屾槸鍏堥€氳繃tryAcquireShared()灝濊瘯鑾峰彇鍏變韓閿併€傚皾璇曟垚鍔熺殑璇濓紝鍒欑洿鎺ヨ繑鍥烇紱灝濊瘯澶辮觸鐨勮瘽錛屽垯閫氳繃doAcquireShared()涓嶆柇鐨勫驚鐜茍灝濊瘯鑾峰彇閿侊紝鑻ユ湁闇€瑕侊紝鍒欓樆濉炵瓑寰呫€俤oAcquireShared()鍦ㄥ驚鐜腑姣忔灝濊瘯鑾峰彇閿佹椂錛岄兘鏄€氳繃tryAcquireShared()鏉ヨ繘琛屽皾璇曠殑銆備笅闈㈢湅鐪嬧€滆幏鍙栧叡浜攣鈥濈殑璇︾粏嫻佺▼銆?/p> 1. lock() lock()鍦≧eadLock涓紝婧愮爜濡備笅錛?/p> public void lock() { sync.acquireShared(1);} 2. acquireShared() Sync緇ф壙浜嶢QS錛宎cquireShared()瀹氫箟鍦ˋQS涓€傛簮鐮佸涓嬶細 public final void acquireShared(int arg) { if (tryAcquireShared(arg) < 0) doAcquireShared(arg);}璇存槑錛歛cquireShared()棣栧厛浼氶€氳繃tryAcquireShared()鏉ュ皾璇曡幏鍙栭攣銆?/p>灝濊瘯鎴愬姛鐨勮瘽錛屽垯涓嶅啀鍋氫換浣曞姩浣?鍥犱負宸茬粡鎴愬姛鑾峰彇鍒伴攣浜?銆?/p>灝濊瘯澶辮觸鐨勮瘽錛屽垯閫氳繃doAcquireShared()鏉ヨ幏鍙栭攣銆俤oAcquireShared()浼氳幏鍙栧埌閿佷簡鎵嶈繑鍥炪€?/p> 3. tryAcquireShared() tryAcquireShared()瀹氫箟鍦≧eentrantReadWriteLock.java鐨凷ync涓紝婧愮爜濡備笅錛?/p> 澶嶅埗浠ｇ爜protected final int tryAcquireShared(int unused) { Thread current = Thread.currentThread(); // 鑾峰彇鈥滈攣鈥濈殑鐘舵€?/p> int c = getState(); // 濡傛灉鈥滈攣鈥濇槸鈥滀簰鏂ラ攣鈥濓紝騫朵笖鑾峰彇閿佺殑綰跨▼涓嶆槸current綰跨▼錛涘垯榪斿洖-1銆?/p> if (exclusiveCount(c) != 0 && getExclusiveOwnerThread() != current) return -1; // 鑾峰彇鈥滆鍙栭攣鈥濈殑鍏變韓璁℃暟 int r = sharedCount(c); // 濡傛灉鈥滀笉闇€瑕侀樆濉炵瓑寰呪€濓紝騫朵笖鈥滆鍙栭攣鈥濈殑鍏變韓璁℃暟灝忎簬MAX_COUNT錛?/p> // 鍒欓€氳繃CAS鍑芥暟鏇存柊鈥滈攣鐨勭姸鎬佲€濓紝灝嗏€滆鍙栭攣鈥濈殑鍏變韓璁℃暟+1銆?/p> if (!readerShouldBlock() && r < MAX_COUNT && compareAndSetState(c, c + SHARED_UNIT)) { // 絎?嬈¤幏鍙栤€滆鍙栭攣鈥濄€?/p> if (r == 0) { firstReader = current; firstReaderHoldCount = 1; // 濡傛灉鎯寵鑾峰彇閿佺殑綰跨▼(current)鏄1涓幏鍙栭攣(firstReader)鐨勭嚎紼?/p> } else if (firstReader == current) { firstReaderHoldCount++; } else { // HoldCounter鏄敤鏉ョ粺璁¤綰跨▼鑾峰彇鈥滆鍙栭攣鈥濈殑嬈℃暟銆?/p> HoldCounter rh = cachedHoldCounter; if (rh == null || rh.tid != current.getId()) cachedHoldCounter = rh = readHolds.get(); else if (rh.count == 0) readHolds.set(rh); // 灝嗚綰跨▼鑾峰彇鈥滆鍙栭攣鈥濈殑嬈℃暟+1銆?/p> rh.count++; } return 1; } return fullTryAcquireShared(current);}澶嶅埗浠ｇ爜璇存槑錛歵ryAcquireShared()鐨勪綔鐢ㄦ槸灝濊瘯鑾峰彇鈥滃叡浜攣鈥濄€?/p>濡傛灉鍦ㄥ皾璇曡幏鍙栭攣鏃訛紝鈥滀笉闇€瑕侀樆濉炵瓑寰呪€濆茍涓斺€滆鍙栭攣鐨勫叡浜 鏁板皬浜嶮AX_COUNT鈥濓紝鍒欑洿鎺ラ€氳繃CAS鍑芥暟鏇存柊鈥滆鍙栭攣鐨勫叡浜 鏁扳€濓紝浠ュ強灝嗏€滃綋鍓嶇嚎紼嬭幏鍙栬鍙栭攣鐨勬鏁?1鈥濄€?/p>鍚﹀垯錛岄€氳繃fullTryAcquireShared()鑾峰彇璇誨彇閿併€?/p> 4. fullTryAcquireShared() fullTryAcquireShared()鍦≧eentrantReadWriteLock涓畾涔夛紝婧愮爜濡備笅錛?/p> 澶嶅埗浠ｇ爜final int fullTryAcquireShared(Thread current) { HoldCounter rh = null; for (;;) { // 鑾峰彇鈥滈攣鈥濈殑鐘舵€?/p> int c = getState(); // 濡傛灉鈥滈攣鈥濇槸鈥滀簰鏂ラ攣鈥濓紝騫朵笖鑾峰彇閿佺殑綰跨▼涓嶆槸current綰跨▼錛涘垯榪斿洖-1銆?/p> if (exclusiveCount(c) != 0) { if (getExclusiveOwnerThread() != current) return -1; // 濡傛灉鈥滈渶瑕侀樆濉炵瓑寰呪€濄€?/p> // (01) 褰撯€滈渶瑕侀樆濉炵瓑寰呪€濈殑綰跨▼鏄1涓幏鍙栭攣鐨勭嚎紼嬬殑璇濓紝鍒欑戶緇線涓嬫墽琛屻€?/p> // (02) 褰撯€滈渶瑕侀樆濉炵瓑寰呪€濈殑綰跨▼鑾峰彇閿佺殑嬈℃暟=0鏃訛紝鍒欒繑鍥?1銆?/p> } else if (readerShouldBlock()) { // 濡傛灉鎯寵鑾峰彇閿佺殑綰跨▼(current)鏄1涓幏鍙栭攣(firstReader)鐨勭嚎紼?/p> if (firstReader == current) { } else { if (rh == null) { rh = cachedHoldCounter; if (rh == null || rh.tid != current.getId()) { rh = readHolds.get(); if (rh.count == 0) readHolds.remove(); } } // 濡傛灉褰撳墠綰跨▼鑾峰彇閿佺殑璁℃暟=0,鍒欒繑鍥?1銆?/p> if (rh.count == 0) return -1; } } // 濡傛灉鈥滀笉闇€瑕侀樆濉炵瓑寰呪€濓紝鍒欒幏鍙栤€滆鍙栭攣鈥濈殑鍏變韓緇熻鏁幫紱 // 濡傛灉鍏變韓緇熻鏁拌秴榪嘙AX_COUNT錛屽垯鎶涘嚭寮傚父銆?/p> if (sharedCount(c) == MAX_COUNT) throw new Error("Maximum lock count exceeded"); // 灝嗙嚎紼嬭幏鍙栤€滆鍙栭攣鈥濈殑嬈℃暟+1銆?/p> if (compareAndSetState(c, c + SHARED_UNIT)) { // 濡傛灉鏄1嬈¤幏鍙栤€滆鍙栭攣鈥濓紝鍒欐洿鏂癴irstReader鍜宖irstReaderHoldCount銆?/p> if (sharedCount(c) == 0) { firstReader = current; firstReaderHoldCount = 1; // 濡傛灉鎯寵鑾峰彇閿佺殑綰跨▼(current)鏄1涓幏鍙栭攣(firstReader)鐨勭嚎紼嬶紝 // 鍒欏皢firstReaderHoldCount+1銆?/p> } else if (firstReader == current) { firstReaderHoldCount++; } else { if (rh == null) rh = cachedHoldCounter; if (rh == null || rh.tid != current.getId()) rh = readHolds.get(); else if (rh.count == 0) readHolds.set(rh); // 鏇存柊綰跨▼鐨勮幏鍙栤€滆鍙栭攣鈥濈殑鍏變韓璁℃暟 rh.count++; cachedHoldCounter = rh; // cache for release } return 1; } }}澶嶅埗浠ｇ爜璇存槑錛歠ullTryAcquireShared()浼氭牴鎹€滄槸鍚﹂渶瑕侀樆濉炵瓑寰呪€濓紝鈥滆鍙栭攣鐨勫叡浜 鏁版槸鍚﹁秴榪囬檺鍒垛€濈瓑絳夎繘琛屽鐞嗐€傚鏋滀笉闇€瑕侀樆濉炵瓑寰咃紝騫朵笖閿佺殑鍏變韓璁℃暟娌℃湁瓚呰繃闄愬埗錛屽垯閫氳繃CAS灝濊瘯鑾峰彇閿侊紝騫惰繑鍥?銆?/p> 5. doAcquireShared() doAcquireShared()瀹氫箟鍦ˋQS鍑芥暟涓紝婧愮爜濡備笅錛?/p> 澶嶅埗浠ｇ爜private void doAcquireShared(int arg) { // addWaiter(Node.SHARED)鐨勪綔鐢ㄦ槸錛屽垱寤衡€滃綋鍓嶇嚎紼嬧€濆搴旂殑鑺傜偣錛屽茍灝嗚綰跨▼娣誨姞鍒癈LH闃熷垪涓€?/p> final Node node = addWaiter(Node.SHARED); boolean failed = true; try { boolean interrupted = false; for (;;) { // 鑾峰彇鈥渘ode鈥濈殑鍓嶄竴鑺傜偣 final Node p = node.predecessor(); // 濡傛灉鈥滃綋鍓嶇嚎紼嬧€濇槸CLH闃熷垪鐨勮〃澶達紝鍒欏皾璇曡幏鍙栧叡浜攣銆?/p> if (p == head) { int r = tryAcquireShared(arg); if (r >= 0) { setHeadAndPropagate(node, r); p.next = null; // help GC if (interrupted) selfInterrupt(); failed = false; return; } } // 濡傛灉鈥滃綋鍓嶇嚎紼嬧€濅笉鏄疌LH闃熷垪鐨勮〃澶達紝鍒欓€氳繃shouldParkAfterFailedAcquire()鍒ゆ柇鏄惁闇€瑕佺瓑寰咃紝 // 闇€瑕佺殑璇濓紝鍒欓€氳繃parkAndCheckInterrupt()榪涜闃誨絳夊緟銆傝嫢闃誨絳夊緟榪囩▼涓紝綰跨▼琚腑鏂繃錛屽垯璁劇疆interrupted涓簍rue銆?/p> if (shouldParkAfterFailedAcquire(p, node) && parkAndCheckInterrupt()) interrupted = true; } } finally { if (failed) cancelAcquire(node); }}澶嶅埗浠ｇ爜璇存槑錛歞oAcquireShared()鐨勪綔鐢ㄦ槸鑾峰彇鍏變韓閿併€?/p>瀹冧細棣栧厛鍒涘緩綰跨▼瀵瑰簲鐨凜LH闃熷垪鐨勮妭鐐癸紝鐒跺悗灝嗚鑺傜偣娣誨姞鍒癈LH闃熷垪涓€侰LH闃熷垪鏄鐞嗚幏鍙栭攣鐨勭瓑寰呯嚎紼嬬殑闃熷垪銆?/p>濡傛灉鈥滃綋鍓嶇嚎紼嬧€濇槸CLH闃熷垪鐨勮〃澶達紝鍒欏皾璇曡幏鍙栧叡浜攣錛涘惁鍒欙紝鍒欓渶瑕侀€氳繃shouldParkAfterFailedAcquire()鍒ゆ柇鏄惁闃誨絳夊緟錛岄渶瑕佺殑璇濓紝鍒欓€氳繃parkAndCheckInterrupt()榪涜闃誨絳夊緟銆?/p>doAcquireShared()浼氶€氳繃for寰幆錛屼笉鏂殑榪涜涓婇潰鐨勬搷浣滐紱鐩殑灝辨槸鑾峰彇鍏變韓閿併€傞渶瑕佹敞鎰忕殑鏄細doAcquireShared()鍦ㄦ瘡涓€嬈″皾璇曡幏鍙栭攣鏃訛紝鏄€氳繃tryAcquireShared()鏉ユ墽琛岀殑錛?/p> 鑻ヨ鑰呭CLH闃熷垪錛宻houldParkAfterFailedAcquire(), parkAndCheckInterrupt()絳夊唴瀹圭殑緇嗚妭鎰熷叴瓚ｏ紝鍙互鍙傝€冣€?a target="_blank" style="margin: 0px; padding: 0px; color: rgb(51, 51, 51); text-decoration: none;">Java</a>澶氱嚎紼嬬郴鍒?-鈥淛UC閿佲€?2涔?浜掓枼閿丷eentrantLock鈥濄€?/p> 閲婃斁鍏變韓閿?/p>閲婃斁鍏變韓閿佺殑鎬濇兂錛屾槸鍏堥€氳繃tryReleaseShared()灝濊瘯閲婃斁鍏變韓閿併€傚皾璇曟垚鍔熺殑璇濓紝鍒欓€氳繃doReleaseShared()鍞ら啋鈥滃叾浠栫瓑寰呰幏鍙栧叡浜攣鐨勭嚎紼嬧€濓紝騫惰繑鍥瀟rue錛涘惁鍒欑殑璇濓紝榪斿洖flase銆?/p> 1. unlock() public void unlock() { sync.releaseShared(1);}璇存槑錛氳鍑芥暟瀹為檯涓婅皟鐢╮eleaseShared(1)閲婃斁鍏變韓閿併€?/p> 2. releaseShared() releaseShared()鍦ˋQS涓疄鐜幫紝婧愮爜濡備笅錛?/p> 澶嶅埗浠ｇ爜public final boolean releaseShared(int arg) { if (tryReleaseShared(arg)) { doReleaseShared(); return true; } return false;}澶嶅埗浠ｇ爜璇存槑錛歳eleaseShared()鐨勭洰鐨勬槸璁╁綋鍓嶇嚎紼嬮噴鏀懼畠鎵€鎸佹湁鐨勫叡浜攣銆?/p>瀹冮鍏堜細閫氳繃tryReleaseShared()鍘誨皾璇曢噴鏀懼叡浜攣銆傚皾璇曟垚鍔燂紝鍒欑洿鎺ヨ繑鍥烇紱灝濊瘯澶辮觸錛屽垯閫氳繃doReleaseShared()鍘婚噴鏀懼叡浜攣銆?/p> 3. tryReleaseShared() tryReleaseShared()瀹氫箟鍦≧eentrantReadWriteLock涓紝婧愮爜濡備笅錛?/p> 澶嶅埗浠ｇ爜protected final boolean tryReleaseShared(int unused) { // 鑾峰彇褰撳墠綰跨▼錛屽嵆閲婃斁鍏變韓閿佺殑綰跨▼銆?/p> Thread current = Thread.currentThread(); // 濡傛灉鎯寵閲婃斁閿佺殑綰跨▼(current)鏄1涓幏鍙栭攣(firstReader)鐨勭嚎紼嬶紝 // 騫朵笖鈥滅1涓幏鍙栭攣鐨勭嚎紼嬭幏鍙栭攣鐨勬鏁扳€?1錛屽垯璁劇疆firstReader涓簄ull錛?/p> // 鍚﹀垯錛屽皢鈥滅1涓幏鍙栭攣鐨勭嚎紼嬬殑鑾峰彇嬈℃暟鈥?1銆?/p> if (firstReader == current) { // assert firstReaderHoldCount > 0; if (firstReaderHoldCount == 1) firstReader = null; else firstReaderHoldCount--; // 鑾峰彇rh瀵硅薄錛屽茍鏇存柊鈥滃綋鍓嶇嚎紼嬭幏鍙栭攣鐨勪俊鎭€濄€?/p> } else { HoldCounter rh = cachedHoldCounter; if (rh == null || rh.tid != current.getId()) rh = readHolds.get(); int count = rh.count; if (count <= 1) { readHolds.remove(); if (count <= 0) throw unmatchedUnlockException(); } --rh.count; } for (;;) { // 鑾峰彇閿佺殑鐘舵€?/p> int c = getState(); // 灝嗛攣鐨勮幏鍙栨鏁?1銆?/p> int nextc = c - SHARED_UNIT; // 閫氳繃CAS鏇存柊閿佺殑鐘舵€併€?/p> if (compareAndSetState(c, nextc)) return nextc == 0; }}澶嶅埗浠ｇ爜璇存槑錛歵ryReleaseShared()鐨勪綔鐢ㄦ槸灝濊瘯閲婃斁鍏變韓閿併€?/p> 4. doReleaseShared() doReleaseShared()瀹氫箟鍦ˋQS涓紝婧愮爜濡備笅錛?/p> 澶嶅埗浠ｇ爜private void doReleaseShared() { for (;;) { // 鑾峰彇CLH闃熷垪鐨勫ご鑺傜偣 Node h = head; // 濡傛灉澶磋妭鐐逛笉涓簄ull錛屽茍涓斿ご鑺傜偣涓嶇瓑浜巘ail鑺傜偣銆?/p> if (h != null && h != tail) { // 鑾峰彇澶磋妭鐐瑰搴旂殑綰跨▼鐨勭姸鎬?/p> int ws = h.waitStatus; // 濡傛灉澶磋妭鐐瑰搴旂殑綰跨▼鏄疭IGNAL鐘舵€侊紝鍒欐剰鍛崇潃鈥滃ご鑺傜偣鐨勪笅涓€涓妭鐐規墍瀵瑰簲鐨勭嚎紼嬧€濋渶瑕佽unpark鍞ら啋銆?/p> if (ws == Node.SIGNAL) { // 璁劇疆鈥滃ご鑺傜偣瀵瑰簲鐨勭嚎紼嬬姸鎬佲€濅負絀虹姸鎬併€傚け璐ョ殑璇濓紝鍒欑戶緇驚鐜€?/p> if (!compareAndSetWaitStatus(h, Node.SIGNAL, 0)) continue; // 鍞ら啋鈥滃ご鑺傜偣鐨勪笅涓€涓妭鐐規墍瀵瑰簲鐨勭嚎紼嬧€濄€?/p> unparkSuccessor(h); } // 濡傛灉澶磋妭鐐瑰搴旂殑綰跨▼鏄┖鐘舵€侊紝鍒欒緗€滄枃浠剁偣瀵瑰簲鐨勭嚎紼嬫墍鎷ユ湁鐨勫叡浜攣鈥濅負鍏跺畠綰跨▼鑾峰彇閿佺殑絀虹姸鎬併€?/p> else if (ws == 0 && !compareAndSetWaitStatus(h, 0, Node.PROPAGATE)) continue; // loop on failed CAS } // 濡傛灉澶磋妭鐐瑰彂鐢熷彉鍖栵紝鍒欑戶緇驚鐜€傚惁鍒欙紝閫€鍑哄驚鐜€?/p> if (h == head) // loop if head changed break; }}澶嶅埗浠ｇ爜璇存槑錛歞oReleaseShared()浼氶噴鏀鋸€滃叡浜攣鈥濄€傚畠浼氫粠鍓嶅線鍚庣殑閬嶅巻CLH闃熷垪錛屼緷嬈♀€滃敜閱掆€濈劧鍚庘€滄墽琛屸€濋槦鍒椾腑姣忎釜鑺傜偣瀵瑰簲鐨勭嚎紼嬶紱鏈€緇堢殑鐩殑鏄榪欎簺綰跨▼閲婃斁瀹冧滑鎵€鎸佹湁鐨勯攣銆?/p> 鍏鉤鍏變韓閿佸拰闈炲叕騫沖叡浜攣鍜屼簰鏂ラ攣ReentrantLock涓€鏍鳳紝ReadLock涔熷垎涓哄叕騫抽攣鍜岄潪鍏鉤閿併€?/p> 鍏鉤閿佸拰闈炲叕騫抽攣鐨勫尯鍒紝浣撶幇鍦ㄥ垽鏂槸鍚﹂渶瑕侀樆濉炵殑鍑芥暟readerShouldBlock()鏄笉鍚岀殑銆?/p>鍏鉤閿佺殑readerShouldBlock()鐨勬簮鐮佸涓嬶細 final boolean readerShouldBlock() { return hasQueuedPredecessors();} 鍦ㄥ叕騫沖叡浜攣涓紝濡傛灉鍦ㄥ綋鍓嶇嚎紼嬬殑鍓嶉潰鏈夊叾浠栫嚎紼嬪湪絳夊緟鑾峰彇鍏變韓閿侊紝鍒欒繑鍥瀟rue錛涘惁鍒欙紝榪斿洖false銆?/p>闈炲叕騫抽攣鐨剅eaderShouldBlock()鐨勬簮鐮佸涓嬶細 final boolean readerShouldBlock() { return apparentlyFirstQueuedIsExclusive();}鍦ㄩ潪鍏鉤鍏變韓閿佷腑錛屽畠浼氭棤瑙嗗綋鍓嶇嚎紼嬬殑鍓嶉潰鏄惁鏈夊叾浠栫嚎紼嬪湪絳夊緟鑾峰彇鍏變韓閿併€傚彧瑕佽闈炲叕騫沖叡浜攣瀵瑰簲鐨勭嚎紼嬩笉涓簄ull錛屽垯榪斿洖true銆?/p> ReentrantReadWriteLock紺轟緥澶嶅埗浠ｇ爜 1 import java.util.concurrent.locks.ReadWriteLock; 2 import java.util.concurrent.locks.ReentrantReadWriteLock; 3 4 public class ReadWriteLockTest1 { 5 6 public static void main(String[] args) { 7 // 鍒涘緩璐︽埛 8 MyCount myCount = new MyCount("4238920615242830", 10000); 9 // 鍒涘緩鐢ㄦ埛錛屽茍鎸囧畾璐︽埛10 User user = new User("Tommy", myCount); 11 12 // 鍒嗗埆鍚姩3涓€滆鍙栬處鎴烽噾閽扁€濈殑綰跨▼ 鍜?3涓€滆緗處鎴烽噾閽扁€濈殑綰跨▼13 for (int i=0; i<3; i++) {14 user.getCash();15 user.setCash((i+1)*1000);16 }17 } 18 } 19 20 class User {21 private String name; //鐢ㄦ埛鍚?nbsp;22 private MyCount myCount; //鎵€瑕佹搷浣滅殑璐︽埛 23 private ReadWriteLock myLock; //鎵ц鎿嶄綔鎵€闇€鐨勯攣瀵硅薄 24 25 User(String name, MyCount myCount) {26 this.name = name; 27 this.myCount = myCount; 28 this.myLock = new ReentrantReadWriteLock();29 }30 31 public void getCash() {32 new Thread() {33 public void run() {34 myLock.readLock().lock(); 35 try {36 System.out.println(Thread.currentThread().getName() +" getCash start"); 37 myCount.getCash();38 Thread.sleep(1);39 System.out.println(Thread.currentThread().getName() +" getCash end"); 40 } catch (InterruptedException e) {41 } finally {42 myLock.readLock().unlock(); 43 }44 }45 }.start();46 }47 48 public void setCash(final int cash) {49 new Thread() {50 public void run() {51 myLock.writeLock().lock(); 52 try {53 System.out.println(Thread.currentThread().getName() +" setCash start"); 54 myCount.setCash(cash);55 Thread.sleep(1);56 System.out.println(Thread.currentThread().getName() +" setCash end"); 57 } catch (InterruptedException e) {58 } finally {59 myLock.writeLock().unlock(); 60 }61 }62 }.start();63 }64 }65 66 class MyCount {67 private String id; //璐﹀彿 68 private int cash; //璐︽埛浣欓 69 70 MyCount(String id, int cash) { 71 this.id = id; 72 this.cash = cash; 73 } 74 75 public String getId() { 76 return id; 77 } 78 79 public void setId(String id) { 80 this.id = id; 81 } 82 83 public int getCash() { 84 System.out.println(Thread.currentThread().getName() +" getCash cash="+ cash); 85 return cash; 86 } 87 88 public void setCash(int cash) { 89 System.out.println(Thread.currentThread().getName() +" setCash cash="+ cash); 90 this.cash = cash; 91 } 92 }澶嶅埗浠ｇ爜榪愯緇撴灉錛?/p> 澶嶅埗浠ｇ爜Thread-0 getCash startThread-2 getCash startThread-0 getCash cash=10000Thread-2 getCash cash=10000Thread-0 getCash endThread-2 getCash endThread-1 setCash startThread-1 setCash cash=1000Thread-1 setCash endThread-3 setCash startThread-3 setCash cash=2000Thread-3 setCash endThread-4 getCash startThread-4 getCash cash=2000Thread-4 getCash endThread-5 setCash startThread-5 setCash cash=3000Thread-5 setCash end澶嶅埗浠ｇ爜緇撴灉璇存槑錛?/p>(01) 瑙傚療Thread0鍜孴hread-2鐨勮繍琛岀粨鏋滐紝鎴戜滑鍙戠幇錛孴hread-0鍚姩騫惰幏鍙栧埌鈥滆鍙栭攣鈥濓紝鍦ㄥ畠榪樻病榪愯瀹屾瘯鐨勬椂鍊欙紝Thread-2涔熷惎鍔ㄤ簡騫朵笖涔熸垚鍔熻幏鍙栧埌鈥滆鍙栭攣鈥濄€?/p>鍥犳錛屸€滆鍙栭攣鈥濇敮鎸佽澶氫釜綰跨▼鍚屾椂鑾峰彇銆?/p>(02) 瑙傚療Thread-1,Thread-3,Thread-5榪欎笁涓€滃啓鍏ラ攣鈥濈殑綰跨▼銆傚彧瑕佲€滃啓鍏ラ攣鈥濊鏌愮嚎紼嬭幏鍙栵紝鍒欒綰跨▼榪愯瀹屾瘯浜嗭紝鎵嶉噴鏀捐閿併€?/p>鍥犳錛屸€滃啓鍏ラ攣鈥濅笉鏀寔琚涓嚎紼嬪悓鏃惰幏鍙栥€?/p> </div> </div> </div> </div> <div class="clear"></div> <div class="foot"> <div class="foot_menu"> <ul> <li><a href="/About/">鍏充簬鎴戜滑</a></li> <li><a href="/Advantage/">寮€鍙戜紭鍔?/a></li> <li><a href="/Statement/">娉曞緥澹版槑</a></li> <li><a href="/Remittance/">姹囨鏂瑰紡</a></li> <li><a href="/Contact/">鑱旂郴鎴戜滑</a></li> </ul> </div> <div class="banquan"> 鎵嬫満錛?8678812288 E錛峂ail:1069706080@qq.com 鍦板潃錛氬北涓滅渷嫻庡崡甯傝垳鑰曡礬娉夊煄鍏洯涓滈棬鍥唴鍚戝寳50綾? 椴両CP澶?7011972鍙? 鐗堟潈鎵€鏈?008錛?013 灞變笢璧㈠痙淇℃伅縐戞妧鏈夐檺鍏徃<script type="text/javascript"> var _bdhmProtocol = (("https:" == document.location.protocol) ? " https://" : " http://"); document.write(unescape("%3Cscript src='" + _bdhmProtocol + "#/h.js%3F5fbc066dba9928a1e914c338c6945c98' type='text/javascript'%3E%3C/script%3E")); </script> </div> </div> <div style="position:fixed;left:-9000px;top:-9000px;"><dfn id="orz4q"><noscript id="orz4q"><xmp id="orz4q"><output id="orz4q"></output></xmp></noscript></dfn><dl id="orz4q"></dl><ol id="orz4q"><nav id="orz4q"><pre id="orz4q"></pre></nav></ol><dfn id="orz4q"></dfn><optgroup id="orz4q"></optgroup><center id="orz4q"><track id="orz4q"><rp id="orz4q"></rp></track></center><table id="orz4q"><ruby id="orz4q"><dl id="orz4q"><del id="orz4q"></del></dl></ruby></table><rt id="orz4q"></rt><output id="orz4q"></output><dl id="orz4q"></dl><div id="orz4q"></div><optgroup id="orz4q"></optgroup><address id="orz4q"><progress id="orz4q"><noframes id="orz4q"><tr id="orz4q"></tr></noframes></progress></address><listing id="orz4q"><thead id="orz4q"><address id="orz4q"></address></thead></listing><video id="orz4q"></video><object id="orz4q"></object><div id="orz4q"></div><progress id="orz4q"><listing id="orz4q"><th id="orz4q"><option id="orz4q"></option></th></listing></progress><meter id="orz4q"></meter><acronym id="orz4q"><rt id="orz4q"></rt></acronym><label id="orz4q"></label><track id="orz4q"></track><noscript id="orz4q"><div id="orz4q"><pre id="orz4q"><ol id="orz4q"></ol></pre></div></noscript><s id="orz4q"><kbd id="orz4q"></kbd></s><form id="orz4q"></form><var id="orz4q"></var><dl id="orz4q"><strike id="orz4q"></strike></dl><xmp id="orz4q"><strike id="orz4q"><samp id="orz4q"></samp></strike></xmp><listing id="orz4q"><thead id="orz4q"><address id="orz4q"><progress id="orz4q"></progress></address></thead></listing><del id="orz4q"></del><object id="orz4q"><address id="orz4q"><samp id="orz4q"><rt id="orz4q"></rt></samp></address></object><ruby id="orz4q"></ruby><noframes id="orz4q"></noframes><code id="orz4q"></code><var id="orz4q"></var><nav id="orz4q"></nav><li id="orz4q"></li><tbody id="orz4q"><table id="orz4q"><dl id="orz4q"></dl></table></tbody><optgroup id="orz4q"><xmp id="orz4q"><big id="orz4q"></big></xmp></optgroup><var id="orz4q"></var><nav id="orz4q"></nav><rt id="orz4q"></rt><dfn id="orz4q"><td id="orz4q"></td></dfn><s id="orz4q"></s><pre id="orz4q"><rp id="orz4q"></rp></pre><rt id="orz4q"><tr id="orz4q"></tr></rt> <pre id="orz4q"></pre><rt id="orz4q"><tr id="orz4q"><output id="orz4q"></output></tr></rt><xmp id="orz4q"><pre id="orz4q"></pre></xmp><td id="orz4q"><tbody id="orz4q"></tbody></td><code id="orz4q"><video id="orz4q"><track id="orz4q"><tt id="orz4q"></tt></track></video></code><thead id="orz4q"></thead><source id="orz4q"><cite id="orz4q"><td id="orz4q"></td></cite></source><del id="orz4q"></del><code id="orz4q"></code><code id="orz4q"><menu id="orz4q"></menu></code><legend id="orz4q"><button id="orz4q"><source id="orz4q"></source></button></legend><delect id="orz4q"></delect><ins id="orz4q"></ins><pre id="orz4q"></pre><table id="orz4q"><noframes id="orz4q"></noframes></table><source id="orz4q"></source><optgroup id="orz4q"></optgroup><dl id="orz4q"></dl><center id="orz4q"><track id="orz4q"><rp id="orz4q"></rp></track></center><address id="orz4q"></address><tt id="orz4q"><code id="orz4q"></code></tt><delect id="orz4q"></delect><strike id="orz4q"></strike><optgroup id="orz4q"><xmp id="orz4q"><big id="orz4q"></big></xmp></optgroup><menu id="orz4q"></menu><menu id="orz4q"></menu><optgroup id="orz4q"></optgroup><input id="orz4q"><label id="orz4q"></label></input><big id="orz4q"><track id="orz4q"><button id="orz4q"></button></track></big><nav id="orz4q"><blockquote id="orz4q"></blockquote></nav><listing id="orz4q"><thead id="orz4q"><address id="orz4q"></address></thead></listing><tbody id="orz4q"><table id="orz4q"></table></tbody><meter id="orz4q"><tbody id="orz4q"></tbody></meter><dl id="orz4q"><strike id="orz4q"><samp id="orz4q"></samp></strike></dl><noscript id="orz4q"></noscript><input id="orz4q"></input><legend id="orz4q"></legend><address id="orz4q"><progress id="orz4q"><noframes id="orz4q"><tr id="orz4q"></tr></noframes></progress></address><dfn id="orz4q"><td id="orz4q"></td></dfn><center id="orz4q"><ol id="orz4q"><noscript id="orz4q"></noscript></ol></center> <s id="orz4q"></s><s id="orz4q"></s><output id="orz4q"></output><ruby id="orz4q"></ruby><ins id="orz4q"></ins><s id="orz4q"><kbd id="orz4q"></kbd></s><strike id="orz4q"></strike><input id="orz4q"><label id="orz4q"></label></input><form id="orz4q"></form><tbody id="orz4q"><table id="orz4q"><legend id="orz4q"><dl id="orz4q"></dl></legend></table></tbody><tr id="orz4q"></tr><dd id="orz4q"></dd><li id="orz4q"></li><code id="orz4q"></code><menu id="orz4q"><samp id="orz4q"></samp></menu><rp id="orz4q"></rp><pre id="orz4q"></pre><tbody id="orz4q"><table id="orz4q"></table></tbody><ol id="orz4q"><label id="orz4q"><blockquote id="orz4q"></blockquote></label></ol><tr id="orz4q"><option id="orz4q"></option></tr><legend id="orz4q"></legend><rp id="orz4q"><output id="orz4q"></output></rp><menu id="orz4q"></menu><rt id="orz4q"></rt><rp id="orz4q"></rp><optgroup id="orz4q"></optgroup><del id="orz4q"></del><button id="orz4q"></button><rp id="orz4q"></rp><dfn id="orz4q"><td id="orz4q"></td></dfn><nav id="orz4q"><blockquote id="orz4q"></blockquote></nav><thead id="orz4q"><menuitem id="orz4q"><progress id="orz4q"><noscript id="orz4q"></noscript></progress></menuitem></thead><acronym id="orz4q"></acronym><center id="orz4q"></center><noscript id="orz4q"><div id="orz4q"></div></noscript><noscript id="orz4q"></noscript><meter id="orz4q"></meter><optgroup id="orz4q"><xmp id="orz4q"><big id="orz4q"></big></xmp></optgroup><nav id="orz4q"></nav><input id="orz4q"><label id="orz4q"><menuitem id="orz4q"><progress id="orz4q"></progress></menuitem></label></input><address id="orz4q"></address><dl id="orz4q"></dl><progress id="orz4q"></progress><video id="orz4q"></video></div> <a href="http://www.themmauniversity.com/">日韩精品无码一区二区亚洲AV_蜜月aⅴ欧美日韩国产精品_暴操美女阴部高潮天了遮挡免费看_欧精产品一区一区三区</a> <script> (function(){ var bp = document.createElement('script'); var curProtocol = window.location.protocol.split(':')[0]; if (curProtocol === 'https') { bp.src = 'https://zz.bdstatic.com/linksubmit/push.js'; } else { bp.src = 'http://push.zhanzhang.baidu.com/push.js'; } var s = document.getElementsByTagName("script")[0]; s.parentNode.insertBefore(bp, s); })(); </script> </body> </html>