Package de.hybris.platform.util
Class WorkerValueQueueTest
java.lang.Object
de.hybris.platform.testframework.HybrisJUnit4Test
de.hybris.platform.util.WorkerValueQueueTest
- All Implemented Interfaces:
JaloSessionHolder
-
Nested Class Summary
Nested Classes -
Field Summary
Fields inherited from class de.hybris.platform.testframework.HybrisJUnit4Test
jaloSession -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voidassertAllPKsUsed(int expectedUseCount) protected voidperformLinearPerformanceTest(WorkerValueQueue<PK> queue1, int cycles, int pkCount) voidsetUp()protected Collection<Thread>simulateWorkers(WorkerValueQueue<PK> queue) protected WorkerValueQueueTest.MastersimulateWriter(WorkerValueQueue<PK> queue, int cycles) voidvoidvoidprotected voidwaitForEmptyQueue(WorkerValueQueue<PK> queue) protected voidwaitForMaster(Thread master) protected voidwaitForWorkers(Collection<Thread> workers) Methods inherited from class de.hybris.platform.testframework.HybrisJUnit4Test
establishJaloSession, finish, getOrCreateCurrency, getOrCreateLanguage, init, intenseChecksActivated, takeJaloSession
-
Constructor Details
-
WorkerValueQueueTest
public WorkerValueQueueTest()
-
-
Method Details
-
setUp
public void setUp() -
testPerformance
public void testPerformance() -
testQueueMultipleCycles
- Throws:
InterruptedException
-
testQueueCompleteness
- Throws:
InterruptedException
-
performLinearPerformanceTest
-
assertAllPKsUsed
protected void assertAllPKsUsed(int expectedUseCount) -
waitForEmptyQueue
-
waitForMaster
- Throws:
InterruptedException
-
waitForWorkers
-
simulateWriter
-
simulateWorkers
protected Collection<Thread> simulateWorkers(WorkerValueQueue<PK> queue) throws InterruptedException - Throws:
InterruptedException
-