de.hybris.platform.util

Class WorkerValueQueueTest

java.lang.Object

de.hybris.platform.testframework.HybrisJUnit4Test

de.hybris.platform.util.WorkerValueQueueTest

@PerformanceTest
public class WorkerValueQueueTest
extends HybrisJUnit4Test

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	WorkerValueQueueTest.Master

Field Summary

Fields inherited from class de.hybris.platform.testframework.HybrisJUnit4Test

defaultLanguage, jaloSession

Constructor Summary

Constructors

Constructor and Description
WorkerValueQueueTest()

Method Summary

Modifier and Type	Method and Description
protected void	assertAllPKsUsed(int expectedUseCount)
protected void	performLinearPerformanceTest(WorkerValueQueue<PK> queue1, int cycles, int pkCount)
void	setUp()
protected Collection<Thread>	simulateWorkers(WorkerValueQueue<PK> queue)
protected WorkerValueQueueTest.Master	simulateWriter(WorkerValueQueue<PK> queue, int cycles)
void	testPerformance()
void	testQueueCompleteness()
void	testQueueMultipleCycles()
protected void	waitForEmptyQueue(WorkerValueQueue<PK> queue)
protected void	waitForMaster(Thread master)
protected void	waitForWorkers(Collection<Thread> workers)

Methods inherited from class de.hybris.platform.testframework.HybrisJUnit4Test

finish, getOrCreateCurrency, getOrCreateLanguage, init, intenseChecksActivated

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkerValueQueueTest

public WorkerValueQueueTest()

Method Detail

setUp

public void setUp()

testPerformance

public void testPerformance()

testQueueMultipleCycles

public void testQueueMultipleCycles()
                             throws InterruptedException

Throws:

InterruptedException

testQueueCompleteness

public void testQueueCompleteness()
                           throws InterruptedException

Throws:

InterruptedException

performLinearPerformanceTest

protected void performLinearPerformanceTest(WorkerValueQueue<PK> queue1,
                                            int cycles,
                                            int pkCount)

assertAllPKsUsed

protected void assertAllPKsUsed(int expectedUseCount)

waitForEmptyQueue

protected void waitForEmptyQueue(WorkerValueQueue<PK> queue)

waitForMaster

protected void waitForMaster(Thread master)
                      throws InterruptedException

Throws:

InterruptedException

waitForWorkers

protected void waitForWorkers(Collection<Thread> workers)

simulateWriter

protected WorkerValueQueueTest.Master simulateWriter(WorkerValueQueue<PK> queue,
                                                     int cycles)

simulateWorkers

protected Collection<Thread> simulateWorkers(WorkerValueQueue<PK> queue)
                                      throws InterruptedException

Throws:

InterruptedException