[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.44, Thu Apr 14 22:55:08 2011 UTC revision 1.45, Fri May 6 11:22:07 2011 UTC
# Line 327  Line 327 
327              }});              }});
328    
329          t.start();          t.start();
330          Thread.sleep(SHORT_DELAY_MS);          delay(SHORT_DELAY_MS);
331          t.interrupt();          t.interrupt();
332          t.join();          t.join();
333          assertEquals(SIZE, q.size());          assertEquals(SIZE, q.size());
# Line 351  Line 351 
351              }});              }});
352    
353          t.start();          t.start();
354          Thread.sleep(SHORT_DELAY_MS);          delay(SHORT_DELAY_MS);
355          assertEquals(q.remainingCapacity(), 0);          assertEquals(q.remainingCapacity(), 0);
356          assertEquals(0, q.take());          assertEquals(0, q.take());
357          Thread.sleep(SHORT_DELAY_MS);          delay(SHORT_DELAY_MS);
358          t.interrupt();          t.interrupt();
359          t.join();          t.join();
360          assertEquals(q.remainingCapacity(), 0);          assertEquals(q.remainingCapacity(), 0);
# Line 377  Line 377 
377              }});              }});
378    
379          t.start();          t.start();
380          Thread.sleep(SHORT_DELAY_MS);          delay(SHORT_DELAY_MS);
381          t.interrupt();          t.interrupt();
382          t.join();          t.join();
383      }      }
# Line 409  Line 409 
409              }});              }});
410    
411          t.start();          t.start();
412          Thread.sleep(SHORT_DELAY_MS);          delay(SHORT_DELAY_MS);
413          t.interrupt();          t.interrupt();
414          t.join();          t.join();
415      }      }
# Line 752  Line 752 
752    
753          executor.execute(new CheckedRunnable() {          executor.execute(new CheckedRunnable() {
754              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
755                  Thread.sleep(SMALL_DELAY_MS);                  delay(SMALL_DELAY_MS);
756                  assertSame(one, q.take());                  assertSame(one, q.take());
757              }});              }});
758    
# Line 774  Line 774 
774    
775          executor.execute(new CheckedRunnable() {          executor.execute(new CheckedRunnable() {
776              public void realRun() throws InterruptedException {              public void realRun() throws InterruptedException {
777                  Thread.sleep(SMALL_DELAY_MS);                  delay(SMALL_DELAY_MS);
778                  q.put(one);                  q.put(one);
779              }});              }});
780    

Legend:
Removed from v.1.44  
changed lines
  Added in v.1.45

Doug Lea
ViewVC Help
Powered by ViewVC 1.0.8