[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.9, Wed Jan 7 01:13:50 2004 UTC revision 1.10, Thu Jan 8 01:29:46 2004 UTC
# Line 319  Line 319 
319       * put blocks interruptibly if full       * put blocks interruptibly if full
320       */       */
321      public void testBlockingPut() {      public void testBlockingPut() {
322            final ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE);
323          Thread t = new Thread(new Runnable() {          Thread t = new Thread(new Runnable() {
324                  public void run() {                  public void run() {
325                      int added = 0;                      int added = 0;
326                      try {                      try {
                         ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE);  
327                          for (int i = 0; i < SIZE; ++i) {                          for (int i = 0; i < SIZE; ++i) {
328                              q.put(new Integer(i));                              q.put(new Integer(i));
329                              ++added;                              ++added;
# Line 336  Line 336 
336                  }});                  }});
337          try {          try {
338              t.start();              t.start();
339             Thread.sleep(SHORT_DELAY_MS);             Thread.sleep(MEDIUM_DELAY_MS);
340             t.interrupt();             t.interrupt();
341             t.join();             t.join();
342          }          }

Legend:
Removed from v.1.9  
changed lines
  Added in v.1.10

Doug Lea
ViewVC Help
Powered by ViewVC 1.0.8