ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/test/tck/SemaphoreTest.java

Comparing jsr166/src/test/tck/SemaphoreTest.java (file contents):
Revision 1.9 by dl, Mon Dec 29 19:05:40 2003 UTC vs.
Revision 1.12 by dl, Sun Jan 4 22:58:03 2004 UTC

#	Line 380 | Line 380 | public class SemaphoreTest extends JSR16
380		}
381		}
382
383	+	/**
384	+	* drainPermits reports and removes given number of permits
385	+	*/
386	+	public void testDrainPermits() {
387	+	Semaphore s = new Semaphore(0, false);
388	+	assertEquals(0, s.availablePermits());
389	+	assertEquals(0, s.drainPermits());
390	+	s.release(10);
391	+	assertEquals(10, s.availablePermits());
392	+	assertEquals(10, s.drainPermits());
393	+	assertEquals(0, s.availablePermits());
394	+	assertEquals(0, s.drainPermits());
395	+	}
396
397		/**
398		* reducePermits reduces number of permits
#	Line 605 | Line 618 | public class SemaphoreTest extends JSR16
618		Thread t = new Thread(new Runnable() {
619		public void run() {
620		try {
621	+	s.acquire();
622	+	s.release(2);
623	+	s.acquire();
624	+	} catch(InterruptedException ie){
625	+	threadUnexpectedException();
626	+	}
627	+	}
628	+	});
629	+	try {
630	+	t.start();
631	+	Thread.sleep(SHORT_DELAY_MS);
632	+	s.release(2);
633	+	s.acquire(2);
634	+	s.release(1);
635	+	t.join();
636	+	} catch( InterruptedException e){
637	+	unexpectedException();
638	+	}
639	+	}
640	+
641	+	/**
642	+	* release(n) in one thread enables acquire(n) in another thread
643	+	*/
644	+	public void testAcquireReleaseNInDifferentThreads_fair2() {
645	+	final Semaphore s = new Semaphore(0, true);
646	+	Thread t = new Thread(new Runnable() {
647	+	public void run() {
648	+	try {
649		s.acquire(2);
650		s.acquire(2);
651		s.release(4);
#	Line 628 | Line 669 | public class SemaphoreTest extends JSR16
669
670
671
672	+
673	+
674		/**
675		* release in one thread enables timed acquire in another thread
676		*/

Diff Legend

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