[cvs] / jsr166 / src / test / tck / AbstractQueuedLongSynchronizerTest.java Repository:
ViewVC logotype

Diff of /jsr166/src/test/tck/AbstractQueuedLongSynchronizerTest.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1.16, Wed Aug 25 00:07:02 2010 UTC revision 1.17, Thu Sep 16 00:52:49 2010 UTC
# Line 47  Line 47 
47              return true;              return true;
48          }          }
49    
50          public AbstractQueuedLongSynchronizer.ConditionObject newCondition() { return new AbstractQueuedLongSynchronizer.ConditionObject(); }          public AbstractQueuedLongSynchronizer.ConditionObject newCondition() {
51                return new AbstractQueuedLongSynchronizer.ConditionObject();
52            }
53    
54      }      }
55    
# Line 348  Line 350 
350          sync.acquire(1);          sync.acquire(1);
351          Thread t = new Thread(new CheckedRunnable() {          Thread t = new Thread(new CheckedRunnable() {
352              public void realRun() {              public void realRun() {
353                  threadAssertFalse(sync.tryAcquire(1));                  assertFalse(sync.tryAcquire(1));
354              }});              }});
355    
356          t.start();          t.start();
# Line 644  Line 646 
646          Thread t = new Thread(new CheckedRunnable() {          Thread t = new Thread(new CheckedRunnable() {
647              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
648                  sync.acquire(1);                  sync.acquire(1);
649                  threadAssertFalse(sync.hasWaiters(c));                  assertFalse(sync.hasWaiters(c));
650                  threadAssertEquals(0, sync.getWaitQueueLength(c));                  assertEquals(0, sync.getWaitQueueLength(c));
651                  c.await();                  c.await();
652                  sync.release(1);                  sync.release(1);
653              }});              }});
# Line 675  Line 677 
677          Thread t1 = new Thread(new CheckedRunnable() {          Thread t1 = new Thread(new CheckedRunnable() {
678              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
679                  sync.acquire(1);                  sync.acquire(1);
680                  threadAssertFalse(sync.hasWaiters(c));                  assertFalse(sync.hasWaiters(c));
681                  threadAssertEquals(0, sync.getWaitQueueLength(c));                  assertEquals(0, sync.getWaitQueueLength(c));
682                  c.await();                  c.await();
683                  sync.release(1);                  sync.release(1);
684              }});              }});
# Line 684  Line 686 
686          Thread t2 = new Thread(new CheckedRunnable() {          Thread t2 = new Thread(new CheckedRunnable() {
687              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
688                  sync.acquire(1);                  sync.acquire(1);
689                  threadAssertTrue(sync.hasWaiters(c));                  assertTrue(sync.hasWaiters(c));
690                  threadAssertEquals(1, sync.getWaitQueueLength(c));                  assertEquals(1, sync.getWaitQueueLength(c));
691                  c.await();                  c.await();
692                  sync.release(1);                  sync.release(1);
693              }});              }});
# Line 719  Line 721 
721          Thread t1 = new Thread(new CheckedRunnable() {          Thread t1 = new Thread(new CheckedRunnable() {
722              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
723                  sync.acquire(1);                  sync.acquire(1);
724                  threadAssertTrue(sync.getWaitingThreads(c).isEmpty());                  assertTrue(sync.getWaitingThreads(c).isEmpty());
725                  c.await();                  c.await();
726                  sync.release(1);                  sync.release(1);
727              }});              }});
# Line 727  Line 729 
729          Thread t2 = new Thread(new CheckedRunnable() {          Thread t2 = new Thread(new CheckedRunnable() {
730              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
731                  sync.acquire(1);                  sync.acquire(1);
732                  threadAssertFalse(sync.getWaitingThreads(c).isEmpty());                  assertFalse(sync.getWaitingThreads(c).isEmpty());
733                  c.await();                  c.await();
734                  sync.release(1);                  sync.release(1);
735              }});              }});
# Line 934  Line 936 
936    
937          Thread t = new Thread(new CheckedRunnable() {          Thread t = new Thread(new CheckedRunnable() {
938              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
939                  threadAssertFalse(l.isSignalled());                  assertFalse(l.isSignalled());
940                  l.acquireSharedInterruptibly(0);                  l.acquireSharedInterruptibly(0);
941                  threadAssertTrue(l.isSignalled());                  assertTrue(l.isSignalled());
942              }});              }});
943    
944          t.start();          t.start();
# Line 973  Line 975 
975      /**      /**
976       * acquireSharedInterruptibly throws IE if interrupted before released       * acquireSharedInterruptibly throws IE if interrupted before released
977       */       */
978      public void testAcquireSharedInterruptibly_InterruptedException() throws InterruptedException {      public void testAcquireSharedInterruptibly_InterruptedException()
979            throws InterruptedException {
980          final BooleanLatch l = new BooleanLatch();          final BooleanLatch l = new BooleanLatch();
981          Thread t = new Thread(new CheckedInterruptedRunnable() {          Thread t = new Thread(new CheckedInterruptedRunnable() {
982              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
983                  threadAssertFalse(l.isSignalled());                  assertFalse(l.isSignalled());
984                  l.acquireSharedInterruptibly(0);                  l.acquireSharedInterruptibly(0);
985              }});              }});
986    

Legend:
Removed from v.1.16  
changed lines
  Added in v.1.17

Doug Lea
ViewVC Help
Powered by ViewVC 1.0.8