public class DelayQueueTest extends JSR166TestCase
JSR166TestCase.AdjustablePolicy, JSR166TestCase.CallableOne, JSR166TestCase.CheckedBarrier, JSR166TestCase.CheckedCallable<T>, JSR166TestCase.CheckedInterruptedCallable<T>, JSR166TestCase.CheckedInterruptedRunnable, JSR166TestCase.CheckedRecursiveAction, JSR166TestCase.CheckedRecursiveTask<T>, JSR166TestCase.CheckedRunnable, JSR166TestCase.LongPossiblyInterruptedRunnable, JSR166TestCase.MediumInterruptedRunnable, JSR166TestCase.MediumPossiblyInterruptedRunnable, JSR166TestCase.MediumRunnable, JSR166TestCase.NoOpCallable, JSR166TestCase.NoOpREHandler, JSR166TestCase.NoOpRunnable, JSR166TestCase.NPETask, JSR166TestCase.RunnableShouldThrow, JSR166TestCase.ShortInterruptedRunnable, JSR166TestCase.ShortRunnable, JSR166TestCase.SimpleThreadFactory, JSR166TestCase.SmallCallable, JSR166TestCase.SmallPossiblyInterruptedRunnable, JSR166TestCase.SmallRunnable, JSR166TestCase.StringTask, JSR166TestCase.ThreadShouldThrow, JSR166TestCase.TrackedCallable, JSR166TestCase.TrackedLongRunnable, JSR166TestCase.TrackedMediumRunnable, JSR166TestCase.TrackedNoOpRunnable, JSR166TestCase.TrackedRunnable, JSR166TestCase.TrackedShortRunnable, JSR166TestCase.TrackedSmallRunnable
eight, expensiveTests, five, four, JAVA_CLASS_VERSION, JAVA_SPECIFICATION_VERSION, LONG_DELAY_MS, m1, m10, m2, m3, m4, m5, m6, MEDIUM_DELAY_MS, nine, one, seven, SHORT_DELAY_MS, six, SIZE, SMALL_DELAY_MS, TEST_STRING, testImplementationDetails, three, two, zero
Constructor and Description |
---|
DelayQueueTest() |
Modifier and Type | Method and Description |
---|---|
protected BlockingQueue |
emptyCollection() |
protected jsr166.DelayQueueTest.PDelay |
makeElement(int i) |
void |
testAdd()
add succeeds
|
void |
testAddAll3()
addAll of a collection with any null elements throws NPE after
possibly adding some elements
|
void |
testAddAll5()
Queue contains all elements of successful addAll
|
void |
testAddAllSelf()
addAll(this) throws IAE
|
void |
testBlockingTake()
Take removes existing elements until empty, then blocks interruptibly
|
void |
testClear()
clear removes all elements
|
void |
testConstructor1()
A new queue has unbounded capacity
|
void |
testConstructor3()
Initializing from null Collection throws NPE
|
void |
testConstructor4()
Initializing from Collection of null elements throws NPE
|
void |
testConstructor5()
Initializing from Collection with some null elements throws NPE
|
void |
testConstructor6()
Queue contains all elements of collection used to initialize
|
void |
testContains()
contains(x) reports true when elements added but not yet removed
|
void |
testContainsAll()
containsAll(c) is true when c contains a subset of elements
|
void |
testDelay()
Delayed actions do not occur until their delay elapses
|
void |
testDrainTo()
drainTo(c) empties queue into another collection c
|
void |
testDrainToN()
drainTo(c, n) empties first min(n, size) elements of queue into c
|
void |
testDrainToWithActivePut()
drainTo empties queue
|
void |
testElement()
element returns next element, or throws NSEE if empty
|
void |
testEmpty()
isEmpty is true before add, false after
|
void |
testEmptyIterator()
iterator of empty collection has no elements
|
void |
testInterruptedTimedPoll()
Interrupted timed poll throws InterruptedException instead of
returning timeout status
|
void |
testIterator()
iterator iterates through all elements
|
void |
testIteratorRemove()
iterator.remove removes current element
|
void |
testNeverContainsNull()
remove(null), contains(null) always return false
|
void |
testOffer()
offer non-null succeeds
|
void |
testPeek()
peek returns next element, or null if empty
|
void |
testPeekDelayed()
peek of a non-empty queue returns non-null even if not expired
|
void |
testPoll()
poll succeeds unless empty
|
void |
testPollDelayed()
poll of a non-empty queue returns null if no expired elements.
|
void |
testPollInExecutor()
timed poll transfers elements across Executor tasks
|
void |
testPut()
all elements successfully put are contained
|
void |
testPutWithTake()
put doesn't block waiting for take
|
void |
testRemainingCapacity()
remainingCapacity() always returns Integer.MAX_VALUE
|
void |
testRemove()
remove removes next element, or throws NSEE if empty
|
void |
testRemoveAll()
removeAll(c) removes only those elements of c and reports true if changed
|
void |
testRetainAll()
retainAll(c) retains only those elements of c and reports true if changed
|
void |
testTake()
take retrieves elements in priority order
|
void |
testTimedOffer()
timed offer does not time out
|
void |
testTimedPoll()
timed poll with nonzero timeout succeeds when non-empty, else times out
|
void |
testTimedPoll0()
timed poll with zero timeout succeeds when non-empty, else times out
|
void |
testTimedPollDelayed()
timed poll of a non-empty queue returns null if no expired elements.
|
void |
testToArray()
toArray contains all elements
|
void |
testToArray1_BadArg()
toArray(incompatible array type) throws ArrayStoreException
|
void |
testToArray2()
toArray(a) contains all elements
|
void |
testToString()
toString contains toStrings of elements
|
addNamedTestClasses, assertIteratorExhausted, assertThrows, atLeastJava10, atLeastJava6, atLeastJava7, atLeastJava8, atLeastJava9, await, await, await, awaiter, countDowner, getShortDelay, jdk8ParameterizedTestSuite, latchAwaitingStringTask, newTestSuite, parameterizedTestSuite, permissivePolicy, possiblyInterruptedRunnable, runBare, runTest, runTestProfiled, runWithoutPermissions, runWithPermissions, runWithSecurityManagerWithPermissions, setDelays, setUp, shouldThrow, shouldThrow, tearDown, testMethodNames, threadAssertEquals, threadAssertEquals, threadAssertFalse, threadAssertNull, threadAssertSame, threadAssertTrue, threadFail, threadRecordFailure, threadShouldThrow, threadShouldThrow, threadUnexpectedException, trackedRunnable
protected BlockingQueue emptyCollection()
protected jsr166.DelayQueueTest.PDelay makeElement(int i)
public void testConstructor1()
public void testConstructor3()
public void testConstructor4()
public void testConstructor5()
public void testConstructor6()
public void testEmpty()
public void testRemainingCapacity()
public void testOffer()
public void testAdd()
public void testAddAllSelf()
public void testAddAll3()
public void testAddAll5()
public void testPut()
public void testPutWithTake() throws InterruptedException
InterruptedException
public void testTimedOffer() throws InterruptedException
InterruptedException
public void testTake() throws InterruptedException
InterruptedException
public void testBlockingTake() throws InterruptedException
InterruptedException
public void testPoll()
public void testTimedPoll0() throws InterruptedException
InterruptedException
public void testTimedPoll() throws InterruptedException
InterruptedException
public void testInterruptedTimedPoll() throws InterruptedException
InterruptedException
public void testPeek()
public void testElement()
public void testRemove()
public void testContains()
public void testClear()
public void testContainsAll()
public void testRetainAll()
public void testRemoveAll()
public void testToArray() throws InterruptedException
InterruptedException
public void testToArray2()
public void testToArray1_BadArg()
public void testIterator()
public void testEmptyIterator()
public void testIteratorRemove()
public void testToString()
public void testPollInExecutor()
public void testDelay() throws InterruptedException
InterruptedException
public void testPeekDelayed()
public void testPollDelayed()
public void testTimedPollDelayed() throws InterruptedException
InterruptedException
public void testDrainTo()
public void testDrainToWithActivePut() throws InterruptedException
InterruptedException
public void testDrainToN()
public void testNeverContainsNull()