public class PriorityBlockingQueueTest 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 |
---|
PriorityBlockingQueueTest() |
Modifier and Type | Method and Description |
---|---|
void |
testAdd()
add of comparable 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 |
testConstructor2()
Constructor throws IAE if capacity argument nonpositive
|
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 |
testConstructor7()
The comparator used in constructor is used
|
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 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 of comparable element succeeds
|
void |
testOfferNonComparable()
Offer of non-Comparable throws CCE
|
void |
testPeek()
peek returns next element, or null if empty
|
void |
testPoll()
poll succeeds unless empty
|
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 |
testSerialization()
A deserialized serialized queue has same elements
|
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 |
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
public void testConstructor1()
public void testConstructor2()
public void testConstructor3()
public void testConstructor4()
public void testConstructor5()
public void testConstructor6()
public void testConstructor7()
public void testEmpty()
public void testRemainingCapacity()
public void testOffer()
public void testOfferNonComparable()
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() throws InterruptedException
InterruptedException
public void testToArray1_BadArg()
public void testIterator()
public void testEmptyIterator()
public void testIteratorRemove()
public void testToString()
public void testPollInExecutor()
public void testSerialization() throws Exception
Exception
public void testDrainTo()
public void testDrainToWithActivePut() throws InterruptedException
InterruptedException
public void testDrainToN()
public void testNeverContainsNull()