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

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

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

revision 1.14, Wed Dec 31 20:09:08 2014 UTC revision 1.22, Fri Jun 22 00:04:58 2018 UTC
# Line 106  Line 106 
106      }      }
107    
108      /**      /**
109       * put(null) throws NullPointerException       * addAll(null) throws NullPointerException
110       */       */
111      public void testAddAllNull() throws InterruptedException {      public void testAddAllNull() throws InterruptedException {
112          final Collection q = emptyCollection();          final Collection q = emptyCollection();
# Line 134  Line 134 
134      public void testToArray_NullArray() {      public void testToArray_NullArray() {
135          final Collection q = emptyCollection();          final Collection q = emptyCollection();
136          try {          try {
137              q.toArray(null);              q.toArray((Object[])null);
138              shouldThrow();              shouldThrow();
139          } catch (NullPointerException success) {}          } catch (NullPointerException success) {}
140      }      }
# Line 189  Line 189 
189      public void testDrainToNonPositiveMaxElements() {      public void testDrainToNonPositiveMaxElements() {
190          final BlockingQueue q = emptyCollection();          final BlockingQueue q = emptyCollection();
191          final int[] ns = { 0, -1, -42, Integer.MIN_VALUE };          final int[] ns = { 0, -1, -42, Integer.MIN_VALUE };
192          for (int n : ns)          final ArrayList sink = new ArrayList();
193              assertEquals(0, q.drainTo(new ArrayList(), n));          for (int n : ns) {
194                assertEquals(0, q.drainTo(sink, n));
195                assertTrue(sink.isEmpty());
196            }
197          if (q.remainingCapacity() > 0) {          if (q.remainingCapacity() > 0) {
198              // Not SynchronousQueue, that is              // Not SynchronousQueue, that is
199              Object one = makeElement(1);              Object one = makeElement(1);
200              q.add(one);              q.add(one);
             ArrayList c = new ArrayList();  
201              for (int n : ns)              for (int n : ns)
202                  assertEquals(0, q.drainTo(new ArrayList(), n));                  assertEquals(0, q.drainTo(sink, n));
203              assertEquals(1, q.size());              assertEquals(1, q.size());
204              assertSame(one, q.poll());              assertSame(one, q.poll());
205              assertTrue(c.isEmpty());              assertTrue(sink.isEmpty());
206          }          }
207      }      }
208    
# Line 235  Line 237 
237                      shouldThrow();                      shouldThrow();
238                  } catch (InterruptedException success) {}                  } catch (InterruptedException success) {}
239                  assertFalse(Thread.interrupted());                  assertFalse(Thread.interrupted());
240    
241                    assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
242              }});              }});
243    
244          barrier.await();          barrier.await();
# Line 243  Line 247 
247          assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);          assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
248    
249          barrier.await();          barrier.await();
250          assertThreadStaysAlive(t);          assertThreadBlocks(t, Thread.State.TIMED_WAITING);
251          t.interrupt();          t.interrupt();
252          awaitTermination(t);          awaitTermination(t);
253      }      }
# Line 265  Line 269 
269              }});              }});
270    
271          await(threadStarted);          await(threadStarted);
272          assertThreadStaysAlive(t);          assertThreadBlocks(t, Thread.State.WAITING);
273          t.interrupt();          t.interrupt();
274          awaitTermination(t);          awaitTermination(t);
275      }      }
# Line 306  Line 310 
310              }});              }});
311    
312          await(threadStarted);          await(threadStarted);
313          assertThreadStaysAlive(t);          assertThreadBlocks(t, Thread.State.TIMED_WAITING);
314          t.interrupt();          t.interrupt();
315          awaitTermination(t);          awaitTermination(t);
316      }      }

Legend:
Removed from v.1.14  
changed lines
  Added in v.1.22

Doug Lea
ViewVC Help
Powered by ViewVC 1.0.8