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.7 by dl, Sat Dec 27 19:26:43 2003 UTC vs.
Revision 1.9 by dl, Mon Dec 29 19:05:40 2003 UTC

# Line 75 | 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 291 | 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 404 | 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 416 | 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