Searched refs:interruptibly (Results 1 – 1 of 1) sorted by relevance
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | QueuesTest.java | 72 long timeout, TimeUnit unit, boolean interruptibly) throws InterruptedException { in drain() argument
73 return interruptibly in drain()
86 for (boolean interruptibly : new boolean[] { true, false }) { in testMultipleProducers()
94 int elements = drain(q, buf, 100, Long.MAX_VALUE, TimeUnit.NANOSECONDS, interruptibly); in testMultipleProducers()
108 for (boolean interruptibly : new boolean[] { true, false }) { in testDrainTimesOut()
117 int drained = drain(q, Lists.newArrayList(), 2, 10, TimeUnit.MILLISECONDS, interruptibly); in testDrainTimesOut()
137 for (boolean interruptibly : new boolean[] { true, false }) { in testZeroElements()
139 assertEquals(0, drain(q, ImmutableList.of(), 0, 10, TimeUnit.MILLISECONDS, interruptibly)); in testZeroElements()
|