ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/test/tck/ReentrantReadWriteLockTest.java

Comparing jsr166/src/test/tck/ReentrantReadWriteLockTest.java (file contents):
Revision 1.14 by dl, Sun Dec 28 22:44:59 2003 UTC vs.
Revision 1.27 by dl, Thu May 18 10:29:23 2006 UTC

#	Line 84 | Line 84 | public class ReentrantReadWriteLockTest
84		rl.writeLock().lock();
85		assertTrue(rl.isWriteLocked());
86		assertTrue(rl.isWriteLockedByCurrentThread());
87	+	assertTrue(rl.writeLock().isHeldByCurrentThread());
88		assertEquals(0, rl.getReadLockCount());
89		rl.writeLock().unlock();
90		assertFalse(rl.isWriteLocked());
91		assertFalse(rl.isWriteLockedByCurrentThread());
92	+	assertFalse(rl.writeLock().isHeldByCurrentThread());
93		assertEquals(0, rl.getReadLockCount());
94		rl.readLock().lock();
95		assertFalse(rl.isWriteLocked());
#	Line 108 | Line 110 | public class ReentrantReadWriteLockTest
110		rl.writeLock().lock();
111		assertTrue(rl.isWriteLocked());
112		assertTrue(rl.isWriteLockedByCurrentThread());
113	+	assertTrue(rl.writeLock().isHeldByCurrentThread());
114		assertEquals(0, rl.getReadLockCount());
115		rl.writeLock().unlock();
116		assertFalse(rl.isWriteLocked());
117		assertFalse(rl.isWriteLockedByCurrentThread());
118	+	assertFalse(rl.writeLock().isHeldByCurrentThread());
119		assertEquals(0, rl.getReadLockCount());
120		rl.readLock().lock();
121		assertFalse(rl.isWriteLocked());
#	Line 126 | Line 130 | public class ReentrantReadWriteLockTest
130		/**
131		* getWriteHoldCount returns number of recursive holds
132		*/
133	<	public void testGetHoldCount() {
133	>	public void testGetWriteHoldCount() {
134		ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
135		for(int i = 1; i <= SIZE; i++) {
136		lock.writeLock().lock();
#	Line 137 | Line 141 | public class ReentrantReadWriteLockTest
141		assertEquals(i-1,lock.getWriteHoldCount());
142		}
143		}
144	+
145	+	/**
146	+	* WriteLock.getHoldCount returns number of recursive holds
147	+	*/
148	+	public void testGetHoldCount() {
149	+	ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
150	+	for(int i = 1; i <= SIZE; i++) {
151	+	lock.writeLock().lock();
152	+	assertEquals(i,lock.writeLock().getHoldCount());
153	+	}
154	+	for(int i = SIZE; i > 0; i--) {
155	+	lock.writeLock().unlock();
156	+	assertEquals(i-1,lock.writeLock().getHoldCount());
157	+	}
158	+	}
159	+
160	+	/**
161	+	* getReadHoldCount returns number of recursive holds
162	+	*/
163	+	public void testGetReadHoldCount() {
164	+	ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
165	+	for(int i = 1; i <= SIZE; i++) {
166	+	lock.readLock().lock();
167	+	assertEquals(i,lock.getReadHoldCount());
168	+	}
169	+	for(int i = SIZE; i > 0; i--) {
170	+	lock.readLock().unlock();
171	+	assertEquals(i-1,lock.getReadHoldCount());
172	+	}
173	+	}
174
175
176		/**
#	Line 156 | Line 190 | public class ReentrantReadWriteLockTest
190		*/
191		public void testWriteLockInterruptibly_Interrupted() {
192		final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
159	–	lock.writeLock().lock();
193		Thread t = new Thread(new Runnable() {
194		public void run() {
195		try {
196		lock.writeLock().lockInterruptibly();
197	<	threadShouldThrow();
197	>	lock.writeLock().unlock();
198	>	lock.writeLock().lockInterruptibly();
199	>	lock.writeLock().unlock();
200		} catch(InterruptedException success){}
201		}
202		});
203		try {
204	+	lock.writeLock().lock();
205		t.start();
206	+	Thread.sleep(SHORT_DELAY_MS);
207		t.interrupt();
208	+	Thread.sleep(SHORT_DELAY_MS);
209		lock.writeLock().unlock();
210		t.join();
211		} catch(Exception e){
#	Line 176 | Line 214 | public class ReentrantReadWriteLockTest
214		}
215
216		/**
217	<	* timed write-trylock is interruptible
217	>	* timed write-tryLock is interruptible
218		*/
219		public void testWriteTryLock_Interrupted() {
220		final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
#	Line 185 | Line 223 | public class ReentrantReadWriteLockTest
223		public void run() {
224		try {
225		lock.writeLock().tryLock(1000,TimeUnit.MILLISECONDS);
188	–	threadShouldThrow();
226		} catch(InterruptedException success){}
227		}
228		});
#	Line 209 | Line 246 | public class ReentrantReadWriteLockTest
246		public void run() {
247		try {
248		lock.readLock().lockInterruptibly();
212	–	threadShouldThrow();
249		} catch(InterruptedException success){}
250		}
251		});
252		try {
253		t.start();
254	+	Thread.sleep(SHORT_DELAY_MS);
255		t.interrupt();
256	+	Thread.sleep(SHORT_DELAY_MS);
257		lock.writeLock().unlock();
258		t.join();
259		} catch(Exception e){
#	Line 224 | Line 262 | public class ReentrantReadWriteLockTest
262		}
263
264		/**
265	<	* timed read-trylock is interruptible
265	>	* timed read-tryLock is interruptible
266		*/
267		public void testReadTryLock_Interrupted() {
268		final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
#	Line 248 | Line 286 | public class ReentrantReadWriteLockTest
286
287
288		/**
289	<	* write-trylock fails if locked
289	>	* write-tryLock fails if locked
290		*/
291		public void testWriteTryLockWhenLocked() {
292		final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
#	Line 268 | Line 306 | public class ReentrantReadWriteLockTest
306		}
307
308		/**
309	<	* read-trylock fails if locked
309	>	* read-tryLock fails if locked
310		*/
311		public void testReadTryLockWhenLocked() {
312		final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
#	Line 376 | Line 414 | public class ReentrantReadWriteLockTest
414		}
415		}
416
417	+	/**
418	+	* Read trylock succeeds if write locked by current thread
419	+	*/
420	+	public void testReadHoldingWriteLock() {
421	+	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
422	+	lock.writeLock().lock();
423	+	assertTrue(lock.readLock().tryLock());
424	+	lock.readLock().unlock();
425	+	lock.writeLock().unlock();
426	+	}
427
428		/**
429	<	* Read trylock succeeds if readlocked but not writelocked
429	>	* Read lock succeeds if write locked by current thread even if
430	>	* other threads are waiting for readlock
431	>	*/
432	>	public void testReadHoldingWriteLock2() {
433	>	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
434	>	lock.writeLock().lock();
435	>	Thread t1 = new Thread(new Runnable() {
436	>	public void run() {
437	>	lock.readLock().lock();
438	>	lock.readLock().unlock();
439	>	}
440	>	});
441	>	Thread t2 = new Thread(new Runnable() {
442	>	public void run() {
443	>	lock.readLock().lock();
444	>	lock.readLock().unlock();
445	>	}
446	>	});
447	>
448	>	try {
449	>	t1.start();
450	>	t2.start();
451	>	lock.readLock().lock();
452	>	lock.readLock().unlock();
453	>	Thread.sleep(SHORT_DELAY_MS);
454	>	lock.readLock().lock();
455	>	lock.readLock().unlock();
456	>	lock.writeLock().unlock();
457	>	t1.join(MEDIUM_DELAY_MS);
458	>	t2.join(MEDIUM_DELAY_MS);
459	>	assertTrue(!t1.isAlive());
460	>	assertTrue(!t2.isAlive());
461	>
462	>	} catch(Exception e){
463	>	unexpectedException();
464	>	}
465	>	}
466	>
467	>	/**
468	>	*  Read lock succeeds if write locked by current thread even if
469	>	* other threads are waiting for writelock
470	>	*/
471	>	public void testReadHoldingWriteLock3() {
472	>	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
473	>	lock.writeLock().lock();
474	>	Thread t1 = new Thread(new Runnable() {
475	>	public void run() {
476	>	lock.writeLock().lock();
477	>	lock.writeLock().unlock();
478	>	}
479	>	});
480	>	Thread t2 = new Thread(new Runnable() {
481	>	public void run() {
482	>	lock.writeLock().lock();
483	>	lock.writeLock().unlock();
484	>	}
485	>	});
486	>
487	>	try {
488	>	t1.start();
489	>	t2.start();
490	>	lock.readLock().lock();
491	>	lock.readLock().unlock();
492	>	Thread.sleep(SHORT_DELAY_MS);
493	>	lock.readLock().lock();
494	>	lock.readLock().unlock();
495	>	lock.writeLock().unlock();
496	>	t1.join(MEDIUM_DELAY_MS);
497	>	t2.join(MEDIUM_DELAY_MS);
498	>	assertTrue(!t1.isAlive());
499	>	assertTrue(!t2.isAlive());
500	>
501	>	} catch(Exception e){
502	>	unexpectedException();
503	>	}
504	>	}
505	>
506	>
507	>	/**
508	>	*  Write lock succeeds if write locked by current thread even if
509	>	* other threads are waiting for writelock
510	>	*/
511	>	public void testWriteHoldingWriteLock4() {
512	>	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
513	>	lock.writeLock().lock();
514	>	Thread t1 = new Thread(new Runnable() {
515	>	public void run() {
516	>	lock.writeLock().lock();
517	>	lock.writeLock().unlock();
518	>	}
519	>	});
520	>	Thread t2 = new Thread(new Runnable() {
521	>	public void run() {
522	>	lock.writeLock().lock();
523	>	lock.writeLock().unlock();
524	>	}
525	>	});
526	>
527	>	try {
528	>	t1.start();
529	>	t2.start();
530	>	lock.writeLock().lock();
531	>	lock.writeLock().unlock();
532	>	Thread.sleep(SHORT_DELAY_MS);
533	>	lock.writeLock().lock();
534	>	lock.writeLock().unlock();
535	>	lock.writeLock().unlock();
536	>	t1.join(MEDIUM_DELAY_MS);
537	>	t2.join(MEDIUM_DELAY_MS);
538	>	assertTrue(!t1.isAlive());
539	>	assertTrue(!t2.isAlive());
540	>
541	>	} catch(Exception e){
542	>	unexpectedException();
543	>	}
544	>	}
545	>
546	>
547	>	/**
548	>	* Fair Read trylock succeeds if write locked by current thread
549	>	*/
550	>	public void testReadHoldingWriteLockFair() {
551	>	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(true);
552	>	lock.writeLock().lock();
553	>	assertTrue(lock.readLock().tryLock());
554	>	lock.readLock().unlock();
555	>	lock.writeLock().unlock();
556	>	}
557	>
558	>	/**
559	>	* Fair Read lock succeeds if write locked by current thread even if
560	>	* other threads are waiting for readlock
561	>	*/
562	>	public void testReadHoldingWriteLockFair2() {
563	>	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(true);
564	>	lock.writeLock().lock();
565	>	Thread t1 = new Thread(new Runnable() {
566	>	public void run() {
567	>	lock.readLock().lock();
568	>	lock.readLock().unlock();
569	>	}
570	>	});
571	>	Thread t2 = new Thread(new Runnable() {
572	>	public void run() {
573	>	lock.readLock().lock();
574	>	lock.readLock().unlock();
575	>	}
576	>	});
577	>
578	>	try {
579	>	t1.start();
580	>	t2.start();
581	>	lock.readLock().lock();
582	>	lock.readLock().unlock();
583	>	Thread.sleep(SHORT_DELAY_MS);
584	>	lock.readLock().lock();
585	>	lock.readLock().unlock();
586	>	lock.writeLock().unlock();
587	>	t1.join(MEDIUM_DELAY_MS);
588	>	t2.join(MEDIUM_DELAY_MS);
589	>	assertTrue(!t1.isAlive());
590	>	assertTrue(!t2.isAlive());
591	>
592	>	} catch(Exception e){
593	>	unexpectedException();
594	>	}
595	>	}
596	>
597	>
598	>	/**
599	>	* Fair Read lock succeeds if write locked by current thread even if
600	>	* other threads are waiting for writelock
601	>	*/
602	>	public void testReadHoldingWriteLockFair3() {
603	>	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(true);
604	>	lock.writeLock().lock();
605	>	Thread t1 = new Thread(new Runnable() {
606	>	public void run() {
607	>	lock.writeLock().lock();
608	>	lock.writeLock().unlock();
609	>	}
610	>	});
611	>	Thread t2 = new Thread(new Runnable() {
612	>	public void run() {
613	>	lock.writeLock().lock();
614	>	lock.writeLock().unlock();
615	>	}
616	>	});
617	>
618	>	try {
619	>	t1.start();
620	>	t2.start();
621	>	lock.readLock().lock();
622	>	lock.readLock().unlock();
623	>	Thread.sleep(SHORT_DELAY_MS);
624	>	lock.readLock().lock();
625	>	lock.readLock().unlock();
626	>	lock.writeLock().unlock();
627	>	t1.join(MEDIUM_DELAY_MS);
628	>	t2.join(MEDIUM_DELAY_MS);
629	>	assertTrue(!t1.isAlive());
630	>	assertTrue(!t2.isAlive());
631	>
632	>	} catch(Exception e){
633	>	unexpectedException();
634	>	}
635	>	}
636	>
637	>
638	>	/**
639	>	* Fair Write lock succeeds if write locked by current thread even if
640	>	* other threads are waiting for writelock
641	>	*/
642	>	public void testWriteHoldingWriteLockFair4() {
643	>	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(true);
644	>	lock.writeLock().lock();
645	>	Thread t1 = new Thread(new Runnable() {
646	>	public void run() {
647	>	lock.writeLock().lock();
648	>	lock.writeLock().unlock();
649	>	}
650	>	});
651	>	Thread t2 = new Thread(new Runnable() {
652	>	public void run() {
653	>	lock.writeLock().lock();
654	>	lock.writeLock().unlock();
655	>	}
656	>	});
657	>
658	>	try {
659	>	t1.start();
660	>	t2.start();
661	>	Thread.sleep(SHORT_DELAY_MS);
662	>	assertTrue(lock.isWriteLockedByCurrentThread());
663	>	assertTrue(lock.getWriteHoldCount() == 1);
664	>	lock.writeLock().lock();
665	>	assertTrue(lock.getWriteHoldCount() == 2);
666	>	lock.writeLock().unlock();
667	>	lock.writeLock().lock();
668	>	lock.writeLock().unlock();
669	>	lock.writeLock().unlock();
670	>	t1.join(MEDIUM_DELAY_MS);
671	>	t2.join(MEDIUM_DELAY_MS);
672	>	assertTrue(!t1.isAlive());
673	>	assertTrue(!t2.isAlive());
674	>
675	>	} catch(Exception e){
676	>	unexpectedException();
677	>	}
678	>	}
679	>
680	>
681	>	/**
682	>	* Read tryLock succeeds if readlocked but not writelocked
683		*/
684		public void testTryLockWhenReadLocked() {
685		final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
#	Line 401 | Line 702 | public class ReentrantReadWriteLockTest
702
703
704		/**
705	<	* write trylock fails when readlocked
705	>	* write tryLock fails when readlocked
706		*/
707		public void testWriteTryLockWhenReadLocked() {
708		final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
#	Line 420 | Line 721 | public class ReentrantReadWriteLockTest
721		}
722		}
723
724	+
725	+	/**
726	+	* Fair Read tryLock succeeds if readlocked but not writelocked
727	+	*/
728	+	public void testTryLockWhenReadLockedFair() {
729	+	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(true);
730	+	lock.readLock().lock();
731	+	Thread t = new Thread(new Runnable() {
732	+	public void run() {
733	+	threadAssertTrue(lock.readLock().tryLock());
734	+	lock.readLock().unlock();
735	+	}
736	+	});
737	+	try {
738	+	t.start();
739	+	t.join();
740	+	lock.readLock().unlock();
741	+	} catch(Exception e){
742	+	unexpectedException();
743	+	}
744	+	}
745	+
746	+
747	+
748	+	/**
749	+	* Fair write tryLock fails when readlocked
750	+	*/
751	+	public void testWriteTryLockWhenReadLockedFair() {
752	+	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(true);
753	+	lock.readLock().lock();
754	+	Thread t = new Thread(new Runnable() {
755	+	public void run() {
756	+	threadAssertFalse(lock.writeLock().tryLock());
757	+	}
758	+	});
759	+	try {
760	+	t.start();
761	+	t.join();
762	+	lock.readLock().unlock();
763	+	} catch(Exception e){
764	+	unexpectedException();
765	+	}
766	+	}
767	+
768
769
770		/**
771	<	* write timed trylock times out if locked
771	>	* write timed tryLock times out if locked
772		*/
773		public void testWriteTryLock_Timeout() {
774		final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
#	Line 447 | Line 792 | public class ReentrantReadWriteLockTest
792		}
793
794		/**
795	<	* read timed trylock times out if write-locked
795	>	* read timed tryLock times out if write-locked
796		*/
797		public void testReadTryLock_Timeout() {
798		final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
#	Line 493 | Line 838 | public class ReentrantReadWriteLockTest
838		});
839		try {
840		t.start();
841	+	Thread.sleep(SHORT_DELAY_MS);
842		t.interrupt();
843	+	Thread.sleep(SHORT_DELAY_MS);
844		t.join();
845		lock.writeLock().unlock();
846		} catch(Exception e){
#	Line 523 | Line 870 | public class ReentrantReadWriteLockTest
870		});
871		try {
872		t.start();
873	+	Thread.sleep(SHORT_DELAY_MS);
874		t.interrupt();
875		t.join();
876		lock.writeLock().unlock();
#	Line 591 | Line 939 | public class ReentrantReadWriteLockTest
939		final Condition c = lock.writeLock().newCondition();
940		try {
941		lock.writeLock().lock();
594	–	assertFalse(c.await(10, TimeUnit.MILLISECONDS));
942		lock.writeLock().unlock();
943		}
944		catch (Exception ex) {
#	Line 608 | Line 955 | public class ReentrantReadWriteLockTest
955		try {
956		lock.writeLock().lock();
957		java.util.Date d = new java.util.Date();
611	–	assertFalse(c.awaitUntil(new java.util.Date(d.getTime() + 10)));
958		lock.writeLock().unlock();
959		}
960		catch (Exception ex) {
#	Line 649 | Line 995 | public class ReentrantReadWriteLockTest
995		}
996		}
997
998	+	/** A helper class for uninterruptible wait tests */
999	+	class UninterruptableThread extends Thread {
1000	+	private Lock lock;
1001	+	private Condition c;
1002	+
1003	+	public volatile boolean canAwake = false;
1004	+	public volatile boolean interrupted = false;
1005	+	public volatile boolean lockStarted = false;
1006	+
1007	+	public UninterruptableThread(Lock lock, Condition c) {
1008	+	this.lock = lock;
1009	+	this.c = c;
1010	+	}
1011	+
1012	+	public synchronized void run() {
1013	+	lock.lock();
1014	+	lockStarted = true;
1015	+
1016	+	while (!canAwake) {
1017	+	c.awaitUninterruptibly();
1018	+	}
1019	+
1020	+	interrupted = isInterrupted();
1021	+	lock.unlock();
1022	+	}
1023	+	}
1024	+
1025		/**
1026		* awaitUninterruptibly doesn't abort on interrupt
1027		*/
1028		public void testAwaitUninterruptibly() {
1029	<	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
1029	>	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
1030		final Condition c = lock.writeLock().newCondition();
1031	<	Thread t = new Thread(new Runnable() {
659	<	public void run() {
660	<	lock.writeLock().lock();
661	<	c.awaitUninterruptibly();
662	<	lock.writeLock().unlock();
663	<	}
664	<	});
1031	>	UninterruptableThread thread = new UninterruptableThread(lock.writeLock(), c);
1032
1033		try {
1034	<	t.start();
1035	<	Thread.sleep(SHORT_DELAY_MS);
1036	<	t.interrupt();
1034	>	thread.start();
1035	>
1036	>	while (!thread.lockStarted) {
1037	>	Thread.sleep(100);
1038	>	}
1039	>
1040		lock.writeLock().lock();
1041	<	c.signal();
1042	<	lock.writeLock().unlock();
1043	<	assert(t.isInterrupted());
1044	<	t.join(SHORT_DELAY_MS);
1045	<	assertFalse(t.isAlive());
1046	<	}
1047	<	catch (Exception ex) {
1041	>	try {
1042	>	thread.interrupt();
1043	>	thread.canAwake = true;
1044	>	c.signal();
1045	>	} finally {
1046	>	lock.writeLock().unlock();
1047	>	}
1048	>
1049	>	thread.join();
1050	>	assertTrue(thread.interrupted);
1051	>	assertFalse(thread.isAlive());
1052	>	} catch (Exception ex) {
1053		unexpectedException();
1054		}
1055		}
#	Line 877 | Line 1252 | public class ReentrantReadWriteLockTest
1252		}
1253
1254		/**
1255	+	* hasQueuedThread(null) throws NPE
1256	+	*/
1257	+	public void testHasQueuedThreadNPE() {
1258	+	final ReentrantReadWriteLock sync = new ReentrantReadWriteLock();
1259	+	try {
1260	+	sync.hasQueuedThread(null);
1261	+	shouldThrow();
1262	+	} catch (NullPointerException success) {
1263	+	}
1264	+	}
1265	+
1266	+	/**
1267	+	* hasQueuedThread reports whether a thread is queued.
1268	+	*/
1269	+	public void testHasQueuedThread() {
1270	+	final ReentrantReadWriteLock sync = new ReentrantReadWriteLock();
1271	+	Thread t1 = new Thread(new InterruptedLockRunnable(sync));
1272	+	Thread t2 = new Thread(new InterruptibleLockRunnable(sync));
1273	+	try {
1274	+	assertFalse(sync.hasQueuedThread(t1));
1275	+	assertFalse(sync.hasQueuedThread(t2));
1276	+	sync.writeLock().lock();
1277	+	t1.start();
1278	+	Thread.sleep(SHORT_DELAY_MS);
1279	+	assertTrue(sync.hasQueuedThread(t1));
1280	+	t2.start();
1281	+	Thread.sleep(SHORT_DELAY_MS);
1282	+	assertTrue(sync.hasQueuedThread(t1));
1283	+	assertTrue(sync.hasQueuedThread(t2));
1284	+	t1.interrupt();
1285	+	Thread.sleep(SHORT_DELAY_MS);
1286	+	assertFalse(sync.hasQueuedThread(t1));
1287	+	assertTrue(sync.hasQueuedThread(t2));
1288	+	sync.writeLock().unlock();
1289	+	Thread.sleep(SHORT_DELAY_MS);
1290	+	assertFalse(sync.hasQueuedThread(t1));
1291	+	Thread.sleep(SHORT_DELAY_MS);
1292	+	assertFalse(sync.hasQueuedThread(t2));
1293	+	t1.join();
1294	+	t2.join();
1295	+	} catch(Exception e){
1296	+	unexpectedException();
1297	+	}
1298	+	}
1299	+
1300	+
1301	+	/**
1302		* getQueueLength reports number of waiting threads
1303		*/
1304		public void testGetQueueLength() {
#	Line 1224 | Line 1646 | public class ReentrantReadWriteLockTest
1646		}
1647		}
1648
1649	+	/**
1650	+	* toString indicates current lock state
1651	+	*/
1652	+	public void testToString() {
1653	+	ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
1654	+	String us = lock.toString();
1655	+	assertTrue(us.indexOf("Write locks = 0") >= 0);
1656	+	assertTrue(us.indexOf("Read locks = 0") >= 0);
1657	+	lock.writeLock().lock();
1658	+	String ws = lock.toString();
1659	+	assertTrue(ws.indexOf("Write locks = 1") >= 0);
1660	+	assertTrue(ws.indexOf("Read locks = 0") >= 0);
1661	+	lock.writeLock().unlock();
1662	+	lock.readLock().lock();
1663	+	lock.readLock().lock();
1664	+	String rs = lock.toString();
1665	+	assertTrue(rs.indexOf("Write locks = 0") >= 0);
1666	+	assertTrue(rs.indexOf("Read locks = 2") >= 0);
1667	+	}
1668	+
1669	+	/**
1670	+	* readLock.toString indicates current lock state
1671	+	*/
1672	+	public void testReadLockToString() {
1673	+	ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
1674	+	String us = lock.readLock().toString();
1675	+	assertTrue(us.indexOf("Read locks = 0") >= 0);
1676	+	lock.readLock().lock();
1677	+	lock.readLock().lock();
1678	+	String rs = lock.readLock().toString();
1679	+	assertTrue(rs.indexOf("Read locks = 2") >= 0);
1680	+	}
1681	+
1682	+	/**
1683	+	* writeLock.toString indicates current lock state
1684	+	*/
1685	+	public void testWriteLockToString() {
1686	+	ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
1687	+	String us = lock.writeLock().toString();
1688	+	assertTrue(us.indexOf("Unlocked") >= 0);
1689	+	lock.writeLock().lock();
1690	+	String ls = lock.writeLock().toString();
1691	+	assertTrue(ls.indexOf("Locked") >= 0);
1692	+	}
1693	+
1694		}

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines