public class StreamerIndexUpdateSync extends Object
Used in StreamerIndexProvider
to synchronize
operations on window index.
StreamerIndexProvider
Constructor and Description |
---|
StreamerIndexUpdateSync() |
Modifier and Type | Method and Description |
---|---|
int |
await()
Waits for a notification from another thread, which
should call
finish(int) with an operation result. |
void |
finish(int res)
Notifies all waiting threads to finish waiting.
|
String |
toString() |
public int await() throws InterruptedException
finish(int)
with an operation result.
That result is returned by this method.finish(int)
.InterruptedException
- If wait was interrupted.public void finish(int res)
res
- Operation result to return from await()
.
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 16 2015