void |
IgniteSemaphore.acquire() |
Acquires a permit from this semaphore, blocking until one is available, or the thread is interrupted. |
void |
IgniteSemaphore.acquire(int permits) |
Acquires the given number of permits from this semaphore, blocking until all are available, or the thread is
interrupted. |
IgniteFuture<?> |
IgniteDataStreamer.addData(Map.Entry<K,V> entry) |
Adds data for streaming on remote node.
|
IgniteFuture<?> |
IgniteDataStreamer.addData(K key,
V val) |
Adds data for streaming on remote node.
|
void |
IgniteCondition.await() |
Causes the current thread to wait until it is signalled or
interrupted. |
boolean |
IgniteCondition.await(long time,
TimeUnit unit) |
Causes the current thread to wait until it is signalled or interrupted,
or the specified waiting time elapses.
|
long |
IgniteCondition.awaitNanos(long nanosTimeout) |
Causes the current thread to wait until it is signalled or interrupted,
or the specified waiting time elapses.
|
boolean |
IgniteCondition.awaitUntil(Date deadline) |
Causes the current thread to wait until it is signalled or interrupted,
or the specified deadline elapses.
|
void |
IgniteDataStreamer.close() |
Closes data streamer.
|
void |
IgniteDataStreamer.close(boolean cancel) |
Streams any remaining data and closes this streamer.
|
void |
IgniteDataStreamer.flush() |
Streams any remaining data, but doesn't close the streamer.
|
void |
IgniteLock.lockInterruptibly() |
Acquires the lock unless the current thread is
interrupted. |
IgniteFuture<?> |
IgniteDataStreamer.removeData(K key) |
Adds key for removal on remote node.
|
boolean |
IgniteSemaphore.tryAcquire(int permits,
long timeout,
TimeUnit unit) |
Acquires the given number of permits from this semaphore, if all become available within the given waiting time
and the current thread has not been interrupted. |
boolean |
IgniteSemaphore.tryAcquire(long timeout,
TimeUnit unit) |
Acquires a permit from this semaphore, if one becomes available within the given waiting time and the current
thread has not been interrupted. |
void |
IgniteDataStreamer.tryFlush() |
Makes an attempt to stream remaining data.
|
boolean |
IgniteLock.tryLock(long timeout,
TimeUnit unit) |
Acquires the lock if it is not held by another thread within the given
waiting time and the current thread has not been
interrupted. |
void |
IgniteLock.unlock() |
Releases the lock.
|