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.19 by dl, Sun Jan 25 13:25:28 2004 UTC vs.
Revision 1.20 by dl, Fri Jul 2 10:24:00 2004 UTC

#	Line 376 | Line 376 | public class ReentrantReadWriteLockTest
376		}
377		}
378
379	+	/**
380	+	* Read trylock succeeds if write locked by current thread
381	+	*/
382	+	public void testReadHoldingWriteLock() {
383	+	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
384	+	lock.writeLock().lock();
385	+	assertTrue(lock.readLock().tryLock());
386	+	lock.readLock().unlock();
387	+	lock.writeLock().unlock();
388	+	}
389	+
390	+	/**
391	+	* Read lock succeeds if write locked by current thread even if
392	+	* other threads are waiting
393	+	*/
394	+	public void testReadHoldingWriteLock2() {
395	+	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
396	+	lock.writeLock().lock();
397	+	Thread t1 = new Thread(new Runnable() {
398	+	public void run() {
399	+	lock.readLock().lock();
400	+	lock.readLock().unlock();
401	+	}
402	+	});
403	+	Thread t2 = new Thread(new Runnable() {
404	+	public void run() {
405	+	lock.readLock().lock();
406	+	lock.readLock().unlock();
407	+	}
408	+	});
409	+
410	+	try {
411	+	t1.start();
412	+	t2.start();
413	+	lock.readLock().lock();
414	+	lock.readLock().unlock();
415	+	Thread.sleep(SHORT_DELAY_MS);
416	+	lock.readLock().lock();
417	+	lock.readLock().unlock();
418	+	lock.writeLock().unlock();
419	+	t1.join(MEDIUM_DELAY_MS);
420	+	t2.join(MEDIUM_DELAY_MS);
421	+	assertTrue(!t1.isAlive());
422	+	assertTrue(!t2.isAlive());
423	+
424	+	} catch(Exception e){
425	+	unexpectedException();
426	+	}
427	+	}
428	+
429	+	/**
430	+	* Fair Read trylock succeeds if write locked by current thread
431	+	*/
432	+	public void testReadHoldingWriteLockFair() {
433	+	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(true);
434	+	lock.writeLock().lock();
435	+	assertTrue(lock.readLock().tryLock());
436	+	lock.readLock().unlock();
437	+	lock.writeLock().unlock();
438	+	}
439	+
440	+	/**
441	+	* Fair Read lock succeeds if write locked by current thread even if
442	+	* other threads are waiting
443	+	*/
444	+	public void testReadHoldingWriteLockFair2() {
445	+	final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(true);
446	+	lock.writeLock().lock();
447	+	Thread t1 = new Thread(new Runnable() {
448	+	public void run() {
449	+	lock.readLock().lock();
450	+	lock.readLock().unlock();
451	+	}
452	+	});
453	+	Thread t2 = new Thread(new Runnable() {
454	+	public void run() {
455	+	lock.readLock().lock();
456	+	lock.readLock().unlock();
457	+	}
458	+	});
459	+
460	+	try {
461	+	t1.start();
462	+	t2.start();
463	+	lock.readLock().lock();
464	+	lock.readLock().unlock();
465	+	Thread.sleep(SHORT_DELAY_MS);
466	+	lock.readLock().lock();
467	+	lock.readLock().unlock();
468	+	lock.writeLock().unlock();
469	+	t1.join(MEDIUM_DELAY_MS);
470	+	t2.join(MEDIUM_DELAY_MS);
471	+	assertTrue(!t1.isAlive());
472	+	assertTrue(!t2.isAlive());
473	+
474	+	} catch(Exception e){
475	+	unexpectedException();
476	+	}
477	+	}
478	+
479
480		/**
481		* Read tryLock succeeds if readlocked but not writelocked

Diff Legend

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