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 Description ThreadSync()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ItemModelTransactionTest.GatecreateGate(java.lang.String key, int parties)Creates a point that allows to ensure a specific number of threads have passed it.ItemModelTransactionTest.JoincreateJoin(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.JoinGatecreateJoinGate(java.lang.String key, int parties)Creates a sync point which ensures that a specified number of threads arrive.booleandestroy()<S extends ItemModelTransactionTest.SyncPoint>
Sget(java.lang.String key)voidregisterThread(java.lang.Thread t)Registers a thread to allow orderly shutdown of testing threads viadestroy().
-
-
-
Method Detail
-
registerThread
public void registerThread(java.lang.Thread t)
Registers a thread to allow orderly shutdown of testing threads viadestroy().
-
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 callsItemModelTransactionTest.JoinGate.waitForAndReleaseAll(long, TimeUnit).This point may be used several times.
-
-