X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=trunk%2Fsupport%2Fgeneral%2Fsrc%2Ftest%2Fjava%2Forg%2Fwamblee%2Fconcurrency%2FReadWriteLockTest.java;h=40302f76a95935b4b0346ea80b6a80819d65239e;hb=8701a4d21c4e35d29dded71950019bd7901b1a03;hp=2c159e9437639c4c563b12d0b0010003ffedfe81;hpb=6087502ede6181aa20b09b19003311156c55d09c;p=utils diff --git a/trunk/support/general/src/test/java/org/wamblee/concurrency/ReadWriteLockTest.java b/trunk/support/general/src/test/java/org/wamblee/concurrency/ReadWriteLockTest.java index 2c159e94..40302f76 100644 --- a/trunk/support/general/src/test/java/org/wamblee/concurrency/ReadWriteLockTest.java +++ b/trunk/support/general/src/test/java/org/wamblee/concurrency/ReadWriteLockTest.java @@ -220,13 +220,15 @@ public class ReadWriteLockTest extends TestCase { WriteLocker writeLocker = new WriteLocker(_lock, this, TWO_SECONDS); Thread t3 = new Thread(writeLocker); - t1.start(); // acquire read lock + t1.start(); // acquire read lock [0, 2.5] Thread.sleep(ONE_SECOND); + // t = 1 assertTrue(getReaderCount() == 1); - t2.start(); + t2.start(); // acquire read lock [1, 3.5] Thread.sleep(HALF_SECOND); + // t = 1.5 assertTrue(getReaderCount() == 2); - t3.start(); + t3.start(); // write lock Thread.sleep(HALF_SECOND); // 2 seconds, @@ -238,7 +240,7 @@ public class ReadWriteLockTest extends TestCase { // have been released. assertTrue(getReaderCount() == 1); assertTrue(getWriterCount() == 0); - Thread.sleep(HALF_SECOND); + Thread.sleep(ONE_SECOND); // 4 seconds underway, write lock must have // been acquired.