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

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

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

revision 1.81, Sun Nov 6 06:27:04 2016 UTC revision 1.82, Sat May 13 21:43:50 2017 UTC
# Line 425  Line 425 
425          final CountDownLatch pleaseInterrupt = new CountDownLatch(1);          final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
426          Thread t = newStartedThread(new CheckedRunnable() {          Thread t = newStartedThread(new CheckedRunnable() {
427              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
428                  for (int i = 0; i < SIZE; ++i) {                  for (int i = 0; i < SIZE; i++) assertEquals(i, q.take());
                     assertEquals(i, q.take());  
                 }  
429    
430                  Thread.currentThread().interrupt();                  Thread.currentThread().interrupt();
431                  try {                  try {
# Line 445  Line 443 
443              }});              }});
444    
445          await(pleaseInterrupt);          await(pleaseInterrupt);
446          assertThreadStaysAlive(t);          assertThreadBlocks(t, Thread.State.WAITING);
447          t.interrupt();          t.interrupt();
448          awaitTermination(t);          awaitTermination(t);
449      }      }

Legend:
Removed from v.1.81  
changed lines
  Added in v.1.82

Doug Lea
ViewVC Help
Powered by ViewVC 1.0.8