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

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

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

revision 1.34, Wed Aug 25 00:07:02 2010 UTC revision 1.35, Thu Sep 16 00:52:49 2010 UTC
# Line 34  Line 34 
34          public boolean isHeldExclusively() { return getState() == 1; }          public boolean isHeldExclusively() { return getState() == 1; }
35    
36          public boolean tryAcquire(int acquires) {          public boolean tryAcquire(int acquires) {
37              assertTrue(acquires == 1);              assertEquals(1, acquires);
38              return compareAndSetState(0, 1);              return compareAndSetState(0, 1);
39          }          }
40    
# Line 44  Line 44 
44              return true;              return true;
45          }          }
46    
47          public AbstractQueuedSynchronizer.ConditionObject newCondition() { return new AbstractQueuedSynchronizer.ConditionObject(); }          public AbstractQueuedSynchronizer.ConditionObject newCondition() {
48                return new AbstractQueuedSynchronizer.ConditionObject();
49            }
50    
51      }      }
52    
# Line 345  Line 347 
347          sync.acquire(1);          sync.acquire(1);
348          Thread t = new Thread(new CheckedRunnable() {          Thread t = new Thread(new CheckedRunnable() {
349              public void realRun() {              public void realRun() {
350                  threadAssertFalse(sync.tryAcquire(1));                  assertFalse(sync.tryAcquire(1));
351              }});              }});
352    
353          t.start();          t.start();
# Line 642  Line 644 
644          Thread t = new Thread(new CheckedRunnable() {          Thread t = new Thread(new CheckedRunnable() {
645              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
646                  sync.acquire(1);                  sync.acquire(1);
647                  threadAssertFalse(sync.hasWaiters(c));                  assertFalse(sync.hasWaiters(c));
648                  threadAssertEquals(0, sync.getWaitQueueLength(c));                  assertEquals(0, sync.getWaitQueueLength(c));
649                  c.await();                  c.await();
650                  sync.release(1);                  sync.release(1);
651              }});              }});
# Line 673  Line 675 
675          Thread t1 = new Thread(new CheckedRunnable() {          Thread t1 = new Thread(new CheckedRunnable() {
676              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
677                  sync.acquire(1);                  sync.acquire(1);
678                  threadAssertFalse(sync.hasWaiters(c));                  assertFalse(sync.hasWaiters(c));
679                  threadAssertEquals(0, sync.getWaitQueueLength(c));                  assertEquals(0, sync.getWaitQueueLength(c));
680                  c.await();                  c.await();
681                  sync.release(1);                  sync.release(1);
682              }});              }});
# Line 682  Line 684 
684          Thread t2 = new Thread(new CheckedRunnable() {          Thread t2 = new Thread(new CheckedRunnable() {
685              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
686                  sync.acquire(1);                  sync.acquire(1);
687                  threadAssertTrue(sync.hasWaiters(c));                  assertTrue(sync.hasWaiters(c));
688                  threadAssertEquals(1, sync.getWaitQueueLength(c));                  assertEquals(1, sync.getWaitQueueLength(c));
689                  c.await();                  c.await();
690                  sync.release(1);                  sync.release(1);
691              }});              }});
# Line 717  Line 719 
719          Thread t1 = new Thread(new CheckedRunnable() {          Thread t1 = new Thread(new CheckedRunnable() {
720              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
721                  sync.acquire(1);                  sync.acquire(1);
722                  threadAssertTrue(sync.getWaitingThreads(c).isEmpty());                  assertTrue(sync.getWaitingThreads(c).isEmpty());
723                  c.await();                  c.await();
724                  sync.release(1);                  sync.release(1);
725              }});              }});
# Line 725  Line 727 
727          Thread t2 = new Thread(new CheckedRunnable() {          Thread t2 = new Thread(new CheckedRunnable() {
728              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
729                  sync.acquire(1);                  sync.acquire(1);
730                  threadAssertFalse(sync.getWaitingThreads(c).isEmpty());                  assertFalse(sync.getWaitingThreads(c).isEmpty());
731                  c.await();                  c.await();
732                  sync.release(1);                  sync.release(1);
733              }});              }});
# Line 932  Line 934 
934    
935          Thread t = new Thread(new CheckedRunnable() {          Thread t = new Thread(new CheckedRunnable() {
936              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
937                  threadAssertFalse(l.isSignalled());                  assertFalse(l.isSignalled());
938                  l.acquireSharedInterruptibly(0);                  l.acquireSharedInterruptibly(0);
939                  threadAssertTrue(l.isSignalled());                  assertTrue(l.isSignalled());
940              }});              }});
941    
942          t.start();          t.start();
# Line 975  Line 977 
977          final BooleanLatch l = new BooleanLatch();          final BooleanLatch l = new BooleanLatch();
978          Thread t = new Thread(new CheckedInterruptedRunnable() {          Thread t = new Thread(new CheckedInterruptedRunnable() {
979              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
980                  threadAssertFalse(l.isSignalled());                  assertFalse(l.isSignalled());
981                  l.acquireSharedInterruptibly(0);                  l.acquireSharedInterruptibly(0);
982              }});              }});
983    

Legend:
Removed from v.1.34  
changed lines
  Added in v.1.35

Doug Lea
ViewVC Help
Powered by ViewVC 1.0.8