--- jsr166/src/test/tck/ReentrantReadWriteLockTest.java 2003/08/31 19:24:55 1.1 +++ jsr166/src/test/tck/ReentrantReadWriteLockTest.java 2003/12/04 20:54:46 1.7 @@ -8,107 +8,1077 @@ import junit.framework.*; import java.util.concurrent.locks.*; import java.util.concurrent.*; +import java.io.*; +import java.util.*; -public class ReentrantReadWriteLockTest extends TestCase { - static int HOLD_COUNT_TEST_LIMIT = 20; - +public class ReentrantReadWriteLockTest extends JSR166TestCase { public static void main(String[] args) { junit.textui.TestRunner.run (suite()); } - public static Test suite() { return new TestSuite(ReentrantReadWriteLockTest.class); } + /** + * A runnable calling lockInterruptibly + */ + class InterruptibleLockRunnable implements Runnable { + final ReentrantReadWriteLock lock; + InterruptibleLockRunnable(ReentrantReadWriteLock l) { lock = l; } + public void run() { + try { + lock.writeLock().lockInterruptibly(); + } catch(InterruptedException success){} + } + } + + + /** + * A runnable calling lockInterruptibly that expects to be + * interrupted + */ + class InterruptedLockRunnable implements Runnable { + final ReentrantReadWriteLock lock; + InterruptedLockRunnable(ReentrantReadWriteLock l) { lock = l; } + public void run() { + try { + lock.writeLock().lockInterruptibly(); + threadShouldThrow(); + } catch(InterruptedException success){} + } + } + + /** + * Subclass to expose protected methods + */ + static class PublicReentrantReadWriteLock extends ReentrantReadWriteLock { + PublicReentrantReadWriteLock() { super(); } + public Collection getQueuedThreads() { + return super.getQueuedThreads(); + } + public PublicCondition newCondition() { + return new PublicCondition(this); + } + + static class PublicCondition extends AbstractReentrantLock.ConditionObject { + PublicCondition(PublicReentrantReadWriteLock l) { super(l); } + public Collection getWaitingThreads() { + return super.getWaitingThreads(); + } + } - private static long SHORT_DELAY_MS = 100; - private static long MEDIUM_DELAY_MS = 1000; - private static long LONG_DELAY_MS = 10000; - - /* - * Unlocks an unlocked lock, throws Illegal Monitor State - * + } + + /** + * Constructor sets given fairness, and is in unlocked state */ + public void testConstructor() { + ReentrantReadWriteLock rl = new ReentrantReadWriteLock(); + assertFalse(rl.isFair()); + assertFalse(rl.isWriteLocked()); + assertEquals(0, rl.getReadLocks()); + ReentrantReadWriteLock r2 = new ReentrantReadWriteLock(true); + assertTrue(r2.isFair()); + assertFalse(r2.isWriteLocked()); + assertEquals(0, r2.getReadLocks()); + } + + /** + * write-locking and read-locking an unlocked lock succeed + */ + public void testLock() { + ReentrantReadWriteLock rl = new ReentrantReadWriteLock(); + rl.writeLock().lock(); + assertTrue(rl.isWriteLocked()); + assertTrue(rl.isWriteLockedByCurrentThread()); + assertEquals(0, rl.getReadLocks()); + rl.writeLock().unlock(); + assertFalse(rl.isWriteLocked()); + assertFalse(rl.isWriteLockedByCurrentThread()); + assertEquals(0, rl.getReadLocks()); + rl.readLock().lock(); + assertFalse(rl.isWriteLocked()); + assertFalse(rl.isWriteLockedByCurrentThread()); + assertEquals(1, rl.getReadLocks()); + rl.readLock().unlock(); + assertFalse(rl.isWriteLocked()); + assertFalse(rl.isWriteLockedByCurrentThread()); + assertEquals(0, rl.getReadLocks()); + } + + + /** + * locking an unlocked fair lock succeeds + */ + public void testFairLock() { + ReentrantReadWriteLock rl = new ReentrantReadWriteLock(true); + rl.writeLock().lock(); + assertTrue(rl.isWriteLocked()); + assertTrue(rl.isWriteLockedByCurrentThread()); + assertEquals(0, rl.getReadLocks()); + rl.writeLock().unlock(); + assertFalse(rl.isWriteLocked()); + assertFalse(rl.isWriteLockedByCurrentThread()); + assertEquals(0, rl.getReadLocks()); + rl.readLock().lock(); + assertFalse(rl.isWriteLocked()); + assertFalse(rl.isWriteLockedByCurrentThread()); + assertEquals(1, rl.getReadLocks()); + rl.readLock().unlock(); + assertFalse(rl.isWriteLocked()); + assertFalse(rl.isWriteLockedByCurrentThread()); + assertEquals(0, rl.getReadLocks()); + } + + /** + * getWriteHoldCount returns number of recursive holds + */ + public void testGetHoldCount() { + ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + for(int i = 1; i <= SIZE; i++) { + lock.writeLock().lock(); + assertEquals(i,lock.getWriteHoldCount()); + } + for(int i = SIZE; i > 0; i--) { + lock.writeLock().unlock(); + assertEquals(i-1,lock.getWriteHoldCount()); + } + } - public void testIllegalMonitorStateException(){ + + /** + * write-unlocking an unlocked lock throws IllegalMonitorStateException + */ + public void testUnlock_IllegalMonitorStateException() { ReentrantReadWriteLock rl = new ReentrantReadWriteLock(); - try{ + try { rl.writeLock().unlock(); - fail("Should of thown Illegal Monitor State Exception"); + shouldThrow(); + } catch(IllegalMonitorStateException success){} + } + + + /** + * write-lockInterruptibly is interruptible + */ + public void testWriteLockInterruptibly_Interrupted() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + lock.writeLock().lock(); + Thread t = new Thread(new Runnable() { + public void run() { + try { + lock.writeLock().lockInterruptibly(); + threadShouldThrow(); + } catch(InterruptedException success){} + } + }); + try { + t.start(); + t.interrupt(); + lock.writeLock().unlock(); + t.join(); + } catch(Exception e){ + unexpectedException(); + } + } - }catch(IllegalMonitorStateException sucess){} + /** + * timed write-trylock is interruptible + */ + public void testWriteTryLock_Interrupted() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + lock.writeLock().lock(); + Thread t = new Thread(new Runnable() { + public void run() { + try { + lock.writeLock().tryLock(1000,TimeUnit.MILLISECONDS); + threadShouldThrow(); + } catch(InterruptedException success){} + } + }); + try { + t.start(); + t.interrupt(); + lock.writeLock().unlock(); + t.join(); + } catch(Exception e){ + unexpectedException(); + } + } + /** + * read-lockInterruptibly is interruptible + */ + public void testReadLockInterruptibly_Interrupted() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + lock.writeLock().lock(); + Thread t = new Thread(new Runnable() { + public void run() { + try { + lock.readLock().lockInterruptibly(); + threadShouldThrow(); + } catch(InterruptedException success){} + } + }); + try { + t.start(); + t.interrupt(); + lock.writeLock().unlock(); + t.join(); + } catch(Exception e){ + unexpectedException(); + } + } + /** + * timed read-trylock is interruptible + */ + public void testReadTryLock_Interrupted() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + lock.writeLock().lock(); + Thread t = new Thread(new Runnable() { + public void run() { + try { + lock.readLock().tryLock(1000,TimeUnit.MILLISECONDS); + threadShouldThrow(); + } catch(InterruptedException success){} + } + }); + try { + t.start(); + t.interrupt(); + t.join(); + } catch(Exception e){ + unexpectedException(); + } } + - /* - * makes a lock, locks it, tries to aquire the lock in another thread - * interrupts that thread and waits for an interrupted Exception to - * be thrown. + /** + * write-trylock fails if locked */ + public void testWriteTryLockWhenLocked() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + lock.writeLock().lock(); + Thread t = new Thread(new Runnable() { + public void run() { + threadAssertFalse(lock.writeLock().tryLock()); + } + }); + try { + t.start(); + t.join(); + lock.writeLock().unlock(); + } catch(Exception e){ + unexpectedException(); + } + } - public void testInterruptedException(){ + /** + * read-trylock fails if locked + */ + public void testReadTryLockWhenLocked() { final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); lock.writeLock().lock(); Thread t = new Thread(new Runnable() { - public void run(){ - try{ - lock.writeLock().lockInterruptibly(); - fail("should throw"); - }catch(InterruptedException sucess){} + public void run() { + threadAssertFalse(lock.readLock().tryLock()); + } + }); + try { + t.start(); + t.join(); + lock.writeLock().unlock(); + } catch(Exception e){ + unexpectedException(); + } + } + + /** + * Multiple threads can hold a read lock when not write-locked + */ + public void testMultipleReadLocks() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + lock.readLock().lock(); + Thread t = new Thread(new Runnable() { + public void run() { + threadAssertTrue(lock.readLock().tryLock()); + lock.readLock().unlock(); + } + }); + try { + t.start(); + t.join(); + lock.readLock().unlock(); + } catch(Exception e){ + unexpectedException(); + } + } + + /** + * A writelock succeeds after reading threads unlock + */ + public void testWriteAfterMultipleReadLocks() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + lock.readLock().lock(); + Thread t1 = new Thread(new Runnable() { + public void run() { + lock.readLock().lock(); + lock.readLock().unlock(); + } + }); + Thread t2 = new Thread(new Runnable() { + public void run() { + lock.writeLock().lock(); + lock.writeLock().unlock(); } }); - t.start(); - t.interrupt(); - lock.writeLock().unlock(); + + try { + t1.start(); + t2.start(); + Thread.sleep(SHORT_DELAY_MS); + lock.readLock().unlock(); + t1.join(MEDIUM_DELAY_MS); + t2.join(MEDIUM_DELAY_MS); + assertTrue(!t1.isAlive()); + assertTrue(!t2.isAlive()); + + } catch(Exception e){ + unexpectedException(); + } } - /* - * tests for interrupted exception on a timed wait - * + /** + * Readlocks succeed after a writing thread unlocks + */ + public void testReadAfterWriteLock() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + lock.writeLock().lock(); + Thread t1 = new Thread(new Runnable() { + public void run() { + lock.readLock().lock(); + lock.readLock().unlock(); + } + }); + Thread t2 = new Thread(new Runnable() { + public void run() { + lock.readLock().lock(); + lock.readLock().unlock(); + } + }); + + try { + t1.start(); + t2.start(); + Thread.sleep(SHORT_DELAY_MS); + lock.writeLock().unlock(); + t1.join(MEDIUM_DELAY_MS); + t2.join(MEDIUM_DELAY_MS); + assertTrue(!t1.isAlive()); + assertTrue(!t2.isAlive()); + + } catch(Exception e){ + unexpectedException(); + } + } + + + /** + * Read trylock succeeds if readlocked but not writelocked + */ + public void testTryLockWhenReadLocked() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + lock.readLock().lock(); + Thread t = new Thread(new Runnable() { + public void run() { + threadAssertTrue(lock.readLock().tryLock()); + lock.readLock().unlock(); + } + }); + try { + t.start(); + t.join(); + lock.readLock().unlock(); + } catch(Exception e){ + unexpectedException(); + } + } + + + + /** + * write trylock fails when readlocked */ + public void testWriteTryLockWhenReadLocked() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + lock.readLock().lock(); + Thread t = new Thread(new Runnable() { + public void run() { + threadAssertFalse(lock.writeLock().tryLock()); + } + }); + try { + t.start(); + t.join(); + lock.readLock().unlock(); + } catch(Exception e){ + unexpectedException(); + } + } + - public void testInterruptedException2(){ + /** + * write timed trylock times out if locked + */ + public void testWriteTryLock_Timeout() { final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); lock.writeLock().lock(); Thread t = new Thread(new Runnable() { - public void run(){ - try{ - lock.writeLock().tryLock(1000,TimeUnit.MILLISECONDS); - fail("should throw"); - }catch(InterruptedException sucess){} + public void run() { + try { + threadAssertFalse(lock.writeLock().tryLock(1, TimeUnit.MILLISECONDS)); + } catch (Exception ex) { + threadUnexpectedException(); + } + } + }); + try { + t.start(); + t.join(); + lock.writeLock().unlock(); + } catch(Exception e){ + unexpectedException(); + } + } + + /** + * read timed trylock times out if write-locked + */ + public void testReadTryLock_Timeout() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + lock.writeLock().lock(); + Thread t = new Thread(new Runnable() { + public void run() { + try { + threadAssertFalse(lock.readLock().tryLock(1, TimeUnit.MILLISECONDS)); + } catch (Exception ex) { + threadUnexpectedException(); + } } }); - t.start(); - t.interrupt(); + try { + t.start(); + t.join(); + lock.writeLock().unlock(); + } catch(Exception e){ + unexpectedException(); + } + } + + + /** + * write lockInterruptibly succeeds if lock free else is interruptible + */ + public void testWriteLockInterruptibly() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + try { + lock.writeLock().lockInterruptibly(); + } catch(Exception e) { + unexpectedException(); + } + Thread t = new Thread(new Runnable() { + public void run() { + try { + lock.writeLock().lockInterruptibly(); + threadShouldThrow(); + } + catch(InterruptedException success) { + } + } + }); + try { + t.start(); + t.interrupt(); + t.join(); + lock.writeLock().unlock(); + } catch(Exception e){ + unexpectedException(); + } } - + /** + * read lockInterruptibly succeeds if lock free else is interruptible + */ + public void testReadLockInterruptibly() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + try { + lock.writeLock().lockInterruptibly(); + } catch(Exception e) { + unexpectedException(); + } + Thread t = new Thread(new Runnable() { + public void run() { + try { + lock.readLock().lockInterruptibly(); + threadShouldThrow(); + } + catch(InterruptedException success) { + } + } + }); + try { + t.start(); + t.interrupt(); + t.join(); + lock.writeLock().unlock(); + } catch(Exception e){ + unexpectedException(); + } + } + + /** + * Calling await without holding lock throws IllegalMonitorStateException + */ + public void testAwait_IllegalMonitor() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + final Condition c = lock.writeLock().newCondition(); + try { + c.await(); + shouldThrow(); + } + catch (IllegalMonitorStateException success) { + } + catch (Exception ex) { + shouldThrow(); + } + } - /* - * current thread locks interruptibly the thread - * another thread tries to aquire the lock and blocks - * on the call. interrupt the attempted aquireLock - * assert that the first lock() call actually locked the lock - * assert that the current thread is the one holding the lock + /** + * Calling signal without holding lock throws IllegalMonitorStateException */ + public void testSignal_IllegalMonitor() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + final Condition c = lock.writeLock().newCondition(); + try { + c.signal(); + shouldThrow(); + } + catch (IllegalMonitorStateException success) { + } + catch (Exception ex) { + unexpectedException(); + } + } - public void testLockedInterruptibly() { + /** + * awaitNanos without a signal times out + */ + public void testAwaitNanos_Timeout() { final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); - try {lock.writeLock().lockInterruptibly();} catch(Exception e) {} + final Condition c = lock.writeLock().newCondition(); + try { + lock.writeLock().lock(); + long t = c.awaitNanos(100); + assertTrue(t <= 0); + lock.writeLock().unlock(); + } + catch (Exception ex) { + unexpectedException(); + } + } + + + /** + * timed await without a signal times out + */ + public void testAwait_Timeout() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + final Condition c = lock.writeLock().newCondition(); + try { + lock.writeLock().lock(); + assertFalse(c.await(10, TimeUnit.MILLISECONDS)); + lock.writeLock().unlock(); + } + catch (Exception ex) { + unexpectedException(); + } + } + + /** + * awaitUntil without a signal times out + */ + public void testAwaitUntil_Timeout() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + final Condition c = lock.writeLock().newCondition(); + try { + lock.writeLock().lock(); + java.util.Date d = new java.util.Date(); + assertFalse(c.awaitUntil(new java.util.Date(d.getTime() + 10))); + lock.writeLock().unlock(); + } + catch (Exception ex) { + unexpectedException(); + } + } + + /** + * await returns when signalled + */ + public void testAwait() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + final Condition c = lock.writeLock().newCondition(); Thread t = new Thread(new Runnable() { public void run() { try { - lock.writeLock().lockInterruptibly(); - fail("Failed to generate an Interrupted Exception"); + lock.writeLock().lock(); + c.await(); + lock.writeLock().unlock(); } - catch(InterruptedException e) {} + catch(InterruptedException e) { + threadUnexpectedException(); + } } }); - t.start(); - t.interrupt(); + + try { + t.start(); + Thread.sleep(SHORT_DELAY_MS); + lock.writeLock().lock(); + c.signal(); + lock.writeLock().unlock(); + t.join(SHORT_DELAY_MS); + assertFalse(t.isAlive()); + } + catch (Exception ex) { + unexpectedException(); + } + } + + /** + * awaitUninterruptibly doesn't abort on interrupt + */ + public void testAwaitUninterruptibly() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + final Condition c = lock.writeLock().newCondition(); + Thread t = new Thread(new Runnable() { + public void run() { + lock.writeLock().lock(); + c.awaitUninterruptibly(); + lock.writeLock().unlock(); + } + }); + + try { + t.start(); + Thread.sleep(SHORT_DELAY_MS); + t.interrupt(); + lock.writeLock().lock(); + c.signal(); + lock.writeLock().unlock(); + assert(t.isInterrupted()); + t.join(SHORT_DELAY_MS); + assertFalse(t.isAlive()); + } + catch (Exception ex) { + unexpectedException(); + } + } + + /** + * await is interruptible + */ + public void testAwait_Interrupt() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + final Condition c = lock.writeLock().newCondition(); + Thread t = new Thread(new Runnable() { + public void run() { + try { + lock.writeLock().lock(); + c.await(); + lock.writeLock().unlock(); + threadShouldThrow(); + } + catch(InterruptedException success) { + } + } + }); + + try { + t.start(); + Thread.sleep(SHORT_DELAY_MS); + t.interrupt(); + t.join(SHORT_DELAY_MS); + assertFalse(t.isAlive()); + } + catch (Exception ex) { + unexpectedException(); + } + } + + /** + * awaitNanos is interruptible + */ + public void testAwaitNanos_Interrupt() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + final Condition c = lock.writeLock().newCondition(); + Thread t = new Thread(new Runnable() { + public void run() { + try { + lock.writeLock().lock(); + c.awaitNanos(SHORT_DELAY_MS * 2 * 1000000); + lock.writeLock().unlock(); + threadShouldThrow(); + } + catch(InterruptedException success) { + } + } + }); + + try { + t.start(); + Thread.sleep(SHORT_DELAY_MS); + t.interrupt(); + t.join(SHORT_DELAY_MS); + assertFalse(t.isAlive()); + } + catch (Exception ex) { + unexpectedException(); + } + } + + /** + * awaitUntil is interruptible + */ + public void testAwaitUntil_Interrupt() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + final Condition c = lock.writeLock().newCondition(); + Thread t = new Thread(new Runnable() { + public void run() { + try { + lock.writeLock().lock(); + java.util.Date d = new java.util.Date(); + c.awaitUntil(new java.util.Date(d.getTime() + 10000)); + lock.writeLock().unlock(); + threadShouldThrow(); + } + catch(InterruptedException success) { + } + } + }); + + try { + t.start(); + Thread.sleep(SHORT_DELAY_MS); + t.interrupt(); + t.join(SHORT_DELAY_MS); + assertFalse(t.isAlive()); + } + catch (Exception ex) { + unexpectedException(); + } + } + + /** + * signalAll wakes up all threads + */ + public void testSignalAll() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + final Condition c = lock.writeLock().newCondition(); + Thread t1 = new Thread(new Runnable() { + public void run() { + try { + lock.writeLock().lock(); + c.await(); + lock.writeLock().unlock(); + } + catch(InterruptedException e) { + threadUnexpectedException(); + } + } + }); + + Thread t2 = new Thread(new Runnable() { + public void run() { + try { + lock.writeLock().lock(); + c.await(); + lock.writeLock().unlock(); + } + catch(InterruptedException e) { + threadUnexpectedException(); + } + } + }); + + try { + t1.start(); + t2.start(); + Thread.sleep(SHORT_DELAY_MS); + lock.writeLock().lock(); + c.signalAll(); + lock.writeLock().unlock(); + t1.join(SHORT_DELAY_MS); + t2.join(SHORT_DELAY_MS); + assertFalse(t1.isAlive()); + assertFalse(t2.isAlive()); + } + catch (Exception ex) { + unexpectedException(); + } + } + + /** + * A serialized lock deserializes as unlocked + */ + public void testSerialization() { + ReentrantReadWriteLock l = new ReentrantReadWriteLock(); + l.readLock().lock(); + l.readLock().unlock(); + + try { + ByteArrayOutputStream bout = new ByteArrayOutputStream(10000); + ObjectOutputStream out = new ObjectOutputStream(new BufferedOutputStream(bout)); + out.writeObject(l); + out.close(); + + ByteArrayInputStream bin = new ByteArrayInputStream(bout.toByteArray()); + ObjectInputStream in = new ObjectInputStream(new BufferedInputStream(bin)); + ReentrantReadWriteLock r = (ReentrantReadWriteLock) in.readObject(); + r.readLock().lock(); + r.readLock().unlock(); + } catch(Exception e){ + e.printStackTrace(); + unexpectedException(); + } + } + + /** + * getQueueLength reports number of waiting threads + */ + public void testGetQueueLength() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + Thread t1 = new Thread(new InterruptedLockRunnable(lock)); + Thread t2 = new Thread(new InterruptibleLockRunnable(lock)); + try { + assertEquals(0, lock.getQueueLength()); + lock.writeLock().lock(); + t1.start(); + Thread.sleep(SHORT_DELAY_MS); + assertEquals(1, lock.getQueueLength()); + t2.start(); + Thread.sleep(SHORT_DELAY_MS); + assertEquals(2, lock.getQueueLength()); + t1.interrupt(); + Thread.sleep(SHORT_DELAY_MS); + assertEquals(1, lock.getQueueLength()); + lock.writeLock().unlock(); + Thread.sleep(SHORT_DELAY_MS); + assertEquals(0, lock.getQueueLength()); + t1.join(); + t2.join(); + } catch(Exception e){ + unexpectedException(); + } + } + + /** + * getQueuedThreads includes waiting threads + */ + public void testGetQueuedThreads() { + final PublicReentrantReadWriteLock lock = new PublicReentrantReadWriteLock(); + Thread t1 = new Thread(new InterruptedLockRunnable(lock)); + Thread t2 = new Thread(new InterruptibleLockRunnable(lock)); + try { + assertTrue(lock.getQueuedThreads().isEmpty()); + lock.writeLock().lock(); + assertTrue(lock.getQueuedThreads().isEmpty()); + t1.start(); + Thread.sleep(SHORT_DELAY_MS); + assertTrue(lock.getQueuedThreads().contains(t1)); + t2.start(); + Thread.sleep(SHORT_DELAY_MS); + assertTrue(lock.getQueuedThreads().contains(t1)); + assertTrue(lock.getQueuedThreads().contains(t2)); + t1.interrupt(); + Thread.sleep(SHORT_DELAY_MS); + assertFalse(lock.getQueuedThreads().contains(t1)); + assertTrue(lock.getQueuedThreads().contains(t2)); + lock.writeLock().unlock(); + Thread.sleep(SHORT_DELAY_MS); + assertTrue(lock.getQueuedThreads().isEmpty()); + t1.join(); + t2.join(); + } catch(Exception e){ + unexpectedException(); + } + } + + /** + * hasWaiters returns true when a thread is waiting, else false + */ + public void testHasWaiters() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + final AbstractReentrantLock.ConditionObject c = (AbstractReentrantLock.ConditionObject)(lock.writeLock().newCondition()); + Thread t = new Thread(new Runnable() { + public void run() { + try { + lock.writeLock().lock(); + threadAssertFalse(c.hasWaiters()); + threadAssertEquals(0, c.getWaitQueueLength()); + c.await(); + lock.writeLock().unlock(); + } + catch(InterruptedException e) { + threadUnexpectedException(); + } + } + }); + + try { + t.start(); + Thread.sleep(SHORT_DELAY_MS); + lock.writeLock().lock(); + assertTrue(c.hasWaiters()); + assertEquals(1, c.getWaitQueueLength()); + c.signal(); + lock.writeLock().unlock(); + Thread.sleep(SHORT_DELAY_MS); + lock.writeLock().lock(); + assertFalse(c.hasWaiters()); + assertEquals(0, c.getWaitQueueLength()); + lock.writeLock().unlock(); + t.join(SHORT_DELAY_MS); + assertFalse(t.isAlive()); + } + catch (Exception ex) { + unexpectedException(); + } + } + + /** + * getWaitQueueLength returns number of waiting threads + */ + public void testGetWaitQueueLength() { + final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(); + final AbstractReentrantLock.ConditionObject c = (AbstractReentrantLock.ConditionObject)(lock.writeLock().newCondition()); + Thread t1 = new Thread(new Runnable() { + public void run() { + try { + lock.writeLock().lock(); + threadAssertFalse(c.hasWaiters()); + threadAssertEquals(0, c.getWaitQueueLength()); + c.await(); + lock.writeLock().unlock(); + } + catch(InterruptedException e) { + threadUnexpectedException(); + } + } + }); + + Thread t2 = new Thread(new Runnable() { + public void run() { + try { + lock.writeLock().lock(); + threadAssertTrue(c.hasWaiters()); + threadAssertEquals(1, c.getWaitQueueLength()); + c.await(); + lock.writeLock().unlock(); + } + catch(InterruptedException e) { + threadUnexpectedException(); + } + } + }); + + try { + t1.start(); + Thread.sleep(SHORT_DELAY_MS); + t2.start(); + Thread.sleep(SHORT_DELAY_MS); + lock.writeLock().lock(); + assertTrue(c.hasWaiters()); + assertEquals(2, c.getWaitQueueLength()); + c.signalAll(); + lock.writeLock().unlock(); + Thread.sleep(SHORT_DELAY_MS); + lock.writeLock().lock(); + assertFalse(c.hasWaiters()); + assertEquals(0, c.getWaitQueueLength()); + lock.writeLock().unlock(); + t1.join(SHORT_DELAY_MS); + t2.join(SHORT_DELAY_MS); + assertFalse(t1.isAlive()); + assertFalse(t2.isAlive()); + } + catch (Exception ex) { + unexpectedException(); + } + } + + /** + * getWaitingThreads returns only and all waiting threads + */ + public void testGetWaitingThreads() { + final PublicReentrantReadWriteLock lock = new PublicReentrantReadWriteLock(); + final PublicReentrantReadWriteLock.PublicCondition c = (PublicReentrantReadWriteLock.PublicCondition)lock.newCondition(); + Thread t1 = new Thread(new Runnable() { + public void run() { + try { + lock.writeLock().lock(); + threadAssertTrue(c.getWaitingThreads().isEmpty()); + c.await(); + lock.writeLock().unlock(); + } + catch(InterruptedException e) { + threadUnexpectedException(); + } + } + }); + + Thread t2 = new Thread(new Runnable() { + public void run() { + try { + lock.writeLock().lock(); + threadAssertFalse(c.getWaitingThreads().isEmpty()); + c.await(); + lock.writeLock().unlock(); + } + catch(InterruptedException e) { + threadUnexpectedException(); + } + } + }); + + try { + lock.writeLock().lock(); + assertTrue(c.getWaitingThreads().isEmpty()); + lock.writeLock().unlock(); + t1.start(); + Thread.sleep(SHORT_DELAY_MS); + t2.start(); + Thread.sleep(SHORT_DELAY_MS); + lock.writeLock().lock(); + assertTrue(c.hasWaiters()); + assertTrue(c.getWaitingThreads().contains(t1)); + assertTrue(c.getWaitingThreads().contains(t2)); + c.signalAll(); + lock.writeLock().unlock(); + Thread.sleep(SHORT_DELAY_MS); + lock.writeLock().lock(); + assertFalse(c.hasWaiters()); + assertTrue(c.getWaitingThreads().isEmpty()); + lock.writeLock().unlock(); + t1.join(SHORT_DELAY_MS); + t2.join(SHORT_DELAY_MS); + assertFalse(t1.isAlive()); + assertFalse(t2.isAlive()); + } + catch (Exception ex) { + unexpectedException(); + } } - }