Package org.redisson.api
Interface RCountDownLatchReactive
-
- All Superinterfaces:
RObjectRx
public interface RCountDownLatchReactive extends RObjectRx
Reactive interface of Redis based It has an advantage over -- count can be set viatrySetCount(long)
method.- Author:
- Nikita Koksharov
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description reactor.core.publisher.Mono<>
await()
Waits until counter reach zero.reactor.core.publisher.Mono<>
await(long waitTime, unit)
Waits until counter reach zero or up to definedtimeout
.reactor.core.publisher.Mono<>
countDown()
Decrements the counter of the latch.reactor.core.publisher.Mono<>
getCount()
Returns value of current count.reactor.core.publisher.Mono<>
trySetCount(long count)
Sets new count value only if previous count already has reached zero or is not set at all.-
Methods inherited from interface org.redisson.api.RObjectRx
addListener, copy, delete, dump, getCodec, getIdleTime, getName, isExists, migrate, move, removeListener, rename, renamenx, restore, restore, restoreAndReplace, restoreAndReplace, sizeInMemory, touch, unlink
-
-
-
-
Method Detail
-
await
reactor.core.publisher.Mono<> await()
Waits until counter reach zero.- Returns:
- void
-
await
reactor.core.publisher.Mono<> await(long waitTime, unit)
Waits until counter reach zero or up to definedtimeout
.- Parameters:
waitTime
- the maximum time to waitunit
- the time unit- Returns:
true
if the count reached zero andfalse
if timeout reached before the count reached zero
-
countDown
reactor.core.publisher.Mono<> countDown()
Decrements the counter of the latch. Notifies all waiting threads when count reaches zero.- Returns:
- void
-
getCount
reactor.core.publisher.Mono<> getCount()
Returns value of current count.- Returns:
- the current count
-
trySetCount
reactor.core.publisher.Mono<> trySetCount(long count)
Sets new count value only if previous count already has reached zero or is not set at all.- Parameters:
count
- - number of timescountDown
must be invoked before threads can pass throughawait
- Returns:
true
if new count settedfalse
if previous count has not reached zero
-
-