de.hybris.platform.servicelayer.tx

Class ItemModelTransactionTest.ThreadSync

java.lang.Object

de.hybris.platform.servicelayer.tx.ItemModelTransactionTest.ThreadSync

Enclosing class:

ItemModelTransactionTest

public static class ItemModelTransactionTest.ThreadSync
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ThreadSync()

Method Summary

Modifier and Type	Method and Description
ItemModelTransactionTest.Gate	createGate(java.lang.String key, int parties) Creates a point that allows to ensure a specific number of threads have passed it.
ItemModelTransactionTest.Join	createJoin(java.lang.String key, int parties) Creates a sync point that causes a specific number of threads to pause until all of them have arrived.
ItemModelTransactionTest.JoinGate	createJoinGate(java.lang.String key, int parties) Creates a sync point which ensures that a specified number of threads arrive.
boolean	destroy()
<S extends ItemModelTransactionTest.SyncPoint> S	get(java.lang.String key)
void	registerThread(java.lang.Thread t) Registers a thread to allow orderly shutdown of testing threads via destroy().

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadSync

public ThreadSync()

Method Detail

registerThread

public void registerThread(java.lang.Thread t)

Registers a thread to allow orderly shutdown of testing threads via destroy().

get

public <S extends ItemModelTransactionTest.SyncPoint> S get(java.lang.String key)

destroy

public boolean destroy()

createGate

public ItemModelTransactionTest.Gate createGate(java.lang.String key,
                                                int parties)

Creates a point that allows to ensure a specific number of threads have passed it. This sync point can only be used once!

createJoin

public ItemModelTransactionTest.Join createJoin(java.lang.String key,
                                                int parties)

Creates a sync point that causes a specific number of threads to pause until all of them have arrived. After that they are released all at once. This sync point may be used several times.

createJoinGate

public ItemModelTransactionTest.JoinGate createJoinGate(java.lang.String key,
                                                        int parties)

Creates a sync point which ensures that a specified number of threads arrive. The are held until the master calls ItemModelTransactionTest.JoinGate.waitForAndReleaseAll(long, TimeUnit). This point may be used several times.