org.gridgain.grid.streamer.index

Class GridStreamerIndexUpdateSync

java.lang.Object

org.gridgain.grid.streamer.index.GridStreamerIndexUpdateSync

public class GridStreamerIndexUpdateSync
extends Object

Streamer index update synchronizer.

Used in GridStreamerIndexProvider to synchronize operations on window index.

See Also:

GridStreamerIndexProvider

Constructor Summary

Constructors

Constructor and Description
GridStreamerIndexUpdateSync()

Method Summary

Methods

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()

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamerIndexUpdateSync

public GridStreamerIndexUpdateSync()

Method Detail

await

public int await()
          throws InterruptedException

Waits for a notification from another thread, which should call finish(int) with an operation result. That result is returned by this method.

Returns:

Operation results, passed to finish(int).

Throws:

InterruptedException - If wait was interrupted.

finish

public void finish(int res)

Notifies all waiting threads to finish waiting.

Parameters:

res - Operation result to return from await().

toString

public String toString()

Overrides:

toString in class Object