public class ThroughputQueueMultiThreadTest
extends com.carrotsearch.randomizedtesting.RandomizedTest
ThroughputQueue
Constructor and Description |
---|
ThroughputQueueMultiThreadTest() |
Modifier and Type | Method and Description |
---|---|
void |
removeLocalMBeans() |
void |
testBlockOnEmptyQueue()
Test that queue will block on Take when queue is empty
|
void |
testBlockOnFullQueue()
Test that queue will block on puts when the queue is full
|
void |
testMultiThreadAccessAndInteruptResponse()
Test multiple threads putting and taking from the queue while
this thread repeatedly calls the MXBean measurement methods.
|
void |
unregisterMXBean()
Remove registered mbeans from previous tests
|
$, $$, assumeFalse, assumeFalse, assumeNoException, assumeNoException, assumeNotNull, assumeTrue, assumeTrue, atLeast, atMost, between, closeAfterSuite, closeAfterTest, frequently, getContext, getRandom, globalTempDir, isNightly, iterations, multiplier, newServerSocket, newTempDir, newTempDir, newTempFile, newTempFile, randomAsciiOfLength, randomAsciiOfLengthBetween, randomBoolean, randomByte, randomDouble, randomFloat, randomFrom, randomFrom, randomGaussian, randomInt, randomInt, randomIntBetween, randomLocale, randomLong, randomRealisticUnicodeOfCodepointLength, randomRealisticUnicodeOfCodepointLengthBetween, randomRealisticUnicodeOfLength, randomRealisticUnicodeOfLengthBetween, randomShort, randomTimeZone, randomUnicodeOfCodepointLength, randomUnicodeOfCodepointLengthBetween, randomUnicodeOfLength, randomUnicodeOfLengthBetween, rarely, scaledRandomIntBetween, sleep, systemPropertyAsBoolean, systemPropertyAsDouble, systemPropertyAsFloat, systemPropertyAsInt, systemPropertyAsLong
assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertThat, assertThat, assertTrue, assertTrue, fail, fail
public void unregisterMXBean() throws Exception
Exception
public void removeLocalMBeans()
public void testBlockOnFullQueue() throws InterruptedException
InterruptedException
public void testBlockOnEmptyQueue() throws InterruptedException
InterruptedException
public void testMultiThreadAccessAndInteruptResponse() throws Exception
Exception
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.