ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/SemaphoreTest.java
(Generate patch)

Comparing jsr166/src/test/tck/SemaphoreTest.java (file contents):
Revision 1.6 by dl, Mon Nov 3 13:50:07 2003 UTC vs.
Revision 1.9 by dl, Mon Dec 29 19:05:40 2003 UTC

# Line 1 | Line 1
1   /*
2 < * Written by members of JCP JSR-166 Expert Group and released to the
3 < * public domain. Use, modify, and redistribute this code in any way
4 < * without acknowledgement. Other contributors include Andrew Wright,
5 < * Jeffrey Hayes, Pat Fischer, Mike Judd.
2 > * Written by Doug Lea with assistance from members of JCP JSR-166
3 > * Expert Group and released to the public domain, as explained at
4 > * http://creativecommons.org/licenses/publicdomain
5 > * Other contributors include Andrew Wright, Jeffrey Hayes,
6 > * Pat Fisher, Mike Judd.
7   */
8  
9   import junit.framework.*;
# Line 74 | Line 75 | public class SemaphoreTest extends JSR16
75      }
76  
77      /**
78 <     * tryAcquire succeeds when sufficent permits, else fails
78 >     * tryAcquire succeeds when sufficient permits, else fails
79       */
80      public void testTryAcquireInSameThread() {
81          Semaphore s = new Semaphore(2, false);
# Line 290 | Line 291 | public class SemaphoreTest extends JSR16
291      }
292  
293      /**
294 +     * hasQueuedThreads reports whether there are waiting threads
295 +     */
296 +    public void testHasQueuedThreads() {
297 +        final Semaphore lock = new Semaphore(1, false);
298 +        Thread t1 = new Thread(new InterruptedLockRunnable(lock));
299 +        Thread t2 = new Thread(new InterruptibleLockRunnable(lock));
300 +        try {
301 +            assertFalse(lock.hasQueuedThreads());
302 +            lock.acquireUninterruptibly();
303 +            t1.start();
304 +            Thread.sleep(SHORT_DELAY_MS);
305 +            assertTrue(lock.hasQueuedThreads());
306 +            t2.start();
307 +            Thread.sleep(SHORT_DELAY_MS);
308 +            assertTrue(lock.hasQueuedThreads());
309 +            t1.interrupt();
310 +            Thread.sleep(SHORT_DELAY_MS);
311 +            assertTrue(lock.hasQueuedThreads());
312 +            lock.release();
313 +            Thread.sleep(SHORT_DELAY_MS);
314 +            assertFalse(lock.hasQueuedThreads());
315 +            t1.join();
316 +            t2.join();
317 +        } catch(Exception e){
318 +            unexpectedException();
319 +        }
320 +    }
321 +
322 +    /**
323       * getQueueLength reports number of waiting threads
324       */
325      public void testGetQueueLength() {
# Line 403 | Line 433 | public class SemaphoreTest extends JSR16
433      }
434  
435      /**
436 <     * tryAcquire succeeds when sufficent permits, else fails
436 >     * tryAcquire succeeds when sufficient permits, else fails
437       */
438      public void testTryAcquireInSameThread_fair() {
439          Semaphore s = new Semaphore(2, true);
# Line 415 | Line 445 | public class SemaphoreTest extends JSR16
445      }
446  
447      /**
448 <     * tryAcquire(n) succeeds when sufficent permits, else fails
448 >     * tryAcquire(n) succeeds when sufficient permits, else fails
449       */
450      public void testTryAcquireNInSameThread_fair() {
451          Semaphore s = new Semaphore(2, true);

Diff Legend

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