Class ConcurrentTestCommandExecutor.Sync
- java.lang.Object
-
- org.apache.calcite.test.concurrent.ConcurrentTestCommandExecutor.Sync
-
- Enclosing class:
- ConcurrentTestCommandExecutor
public static class ConcurrentTestCommandExecutor.Sync extends java.lang.Object
Synchronization object that allows multiple ConcurrentTestCommandExecutors to execute commands in lock-step. Requires that all ConcurrentTestCommandExecutors have the same number of commands.
-
-
Field Summary
Fields Modifier and Type Field Description private int
numThreads
private int
numWaiting
-
Constructor Summary
Constructors Constructor Description Sync(int numThreads)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
waitForOthers()
-