public class LinkedBlockingQueueTest 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 |
---|
LinkedBlockingQueueTest() |
Modifier and Type | Method and Description |
---|---|
void |
testAdd()
add succeeds if not full; throws IllegalStateException if full
|
void |
testAddAll3()
addAll of a collection with any null elements throws NPE after
possibly adding some elements
|
void |
testAddAll4()
addAll throws IllegalStateException if not enough room
|
void |
testAddAll5()
Queue contains all elements, in traversal order, of successful addAll
|
void |
testAddAllSelf()
addAll(this) throws IllegalArgumentException
|
void |
testBlockingPut()
put blocks interruptibly if full
|
void |
testBlockingTake()
Take removes existing elements until empty, then blocks interruptibly
|
void |
testClear()
clear removes all elements
|
void |
testConstructor1()
A new queue has the indicated capacity, or Integer.MAX_VALUE if
none given
|
void |
testConstructor2()
Constructor throws IllegalArgumentException if capacity argument nonpositive
|
void |
testConstructor3()
Initializing from null Collection throws NullPointerException
|
void |
testConstructor4()
Initializing from Collection of null elements throws NullPointerException
|
void |
testConstructor5()
Initializing from Collection with some null elements throws
NullPointerException
|
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 |
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 full queue, unblocking a waiting put.
|
void |
testElement()
element returns next element, or throws NSEE if empty
|
void |
testEmptyFull()
Queue transitions from empty to full when elements added
|
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 |
testIteratorOrdering()
iterator ordering is FIFO
|
void |
testIteratorRemove()
iterator.remove removes current element
|
void |
testNeverContainsNull()
remove(null), contains(null) always return false
|
void |
testOffer()
Offer succeeds if not full; fails if full
|
void |
testOfferInExecutor()
offer transfers elements across Executor tasks
|
void |
testPeek()
peek returns next element, or null if empty
|
void |
testPoll()
poll succeeds unless empty
|
void |
testPollInExecutor()
timed poll retrieves elements across Executor threads
|
void |
testPut()
all elements successfully put are contained
|
void |
testPutWithTake()
put blocks interruptibly waiting for take when full
|
void |
testRemainingCapacity()
remainingCapacity decreases on add, increases on remove
|
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 |
testRemoveElementAndAdd()
An add following remove(x) succeeds
|
void |
testRetainAll()
retainAll(c) retains only those elements of c and reports true if changed
|
void |
testSerialization()
A deserialized serialized queue has same elements in same order
|
void |
testTake()
take retrieves elements in FIFO order
|
void |
testTimedOffer()
timed offer times out if full and elements not taken
|
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 |
testToArray()
toArray contains all elements in FIFO order
|
void |
testToArray1_BadArg()
toArray(incompatible array type) throws ArrayStoreException
|
void |
testToArray2()
toArray(a) contains all elements in FIFO order
|
void |
testToString()
toString contains toStrings of elements
|
void |
testWeaklyConsistentIteration()
Modifications do not cause iterators to fail
|
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
public void testConstructor1()
public void testConstructor2()
public void testConstructor3()
public void testConstructor4()
public void testConstructor5()
public void testConstructor6()
public void testEmptyFull()
public void testRemainingCapacity()
public void testOffer()
public void testAdd()
public void testAddAllSelf()
public void testAddAll3()
public void testAddAll4()
public void testAddAll5()
public void testPut() throws InterruptedException
InterruptedException
public void testBlockingPut() throws InterruptedException
InterruptedException
public void testPutWithTake() throws InterruptedException
InterruptedException
public void testTimedOffer()
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 testRemoveElementAndAdd() throws InterruptedException
InterruptedException
public void testContains()
public void testClear()
public void testContainsAll()
public void testRetainAll()
public void testRemoveAll()
public void testToArray()
public void testToArray2() throws InterruptedException
InterruptedException
public void testToArray1_BadArg()
public void testIterator() throws InterruptedException
InterruptedException
public void testEmptyIterator()
public void testIteratorRemove()
public void testIteratorOrdering()
public void testWeaklyConsistentIteration()
public void testToString()
public void testOfferInExecutor()
public void testPollInExecutor()
public void testSerialization() throws Exception
Exception
public void testDrainTo()
public void testDrainToWithActivePut() throws InterruptedException
InterruptedException
public void testDrainToN()
public void testNeverContainsNull()