Package com.couchbase.client.core.transaction.util

Class ReactiveLock

java.lang.Object

com.couchbase.client.core.transaction.util.ReactiveLock

@Internal
public class ReactiveLock
extends Object

A mutex pessimistic lock, compatible with reactive.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ReactiveLock.Waiter

Constructor Summary

Constructors

Constructor	Description
ReactiveLock(CoreTransactionAttemptContext ctx, boolean debugMode)

Method Summary

Modifier and Type	Method	Description
boolean	debugAsSingleThreaded()
boolean	isLocked()
reactor.core.publisher.Mono<ReactiveLock.Waiter>	lock(String dbg, Duration timeout)	if the lock is unlocked, lock it, and continue else if the lock is locked, join the list of things waiting for it to be unlocked
reactor.core.publisher.Mono<Void>	unlock(ReactiveLock.Waiter waiter)	The thing currently waiting on this lock is now unlocking it.
reactor.core.publisher.Mono<Void>	unlock(ReactiveLock.Waiter waiter, String extraDbg)
reactor.core.publisher.Mono<Void>	unlock(ReactiveLock.Waiter waiter, String extraDbg, boolean removeFromWaiters)

Methods inherited from class java.lang.Object

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

Constructor Details

ReactiveLock

public ReactiveLock(CoreTransactionAttemptContext ctx,
 boolean debugMode)

Method Details

lock

public reactor.core.publisher.Mono<ReactiveLock.Waiter> lock(String dbg,
 Duration timeout)

if the lock is unlocked, lock it, and continue else if the lock is locked, join the list of things waiting for it to be unlocked

unlock

public reactor.core.publisher.Mono<Void> unlock(ReactiveLock.Waiter waiter)

The thing currently waiting on this lock is now unlocking it. Let one (and only one) thing waiting on this lock, continue.

It's reactive style as always need to do a .timeout() after it

unlock

public reactor.core.publisher.Mono<Void> unlock(ReactiveLock.Waiter waiter,
 @Nullable
 String extraDbg)

unlock

public reactor.core.publisher.Mono<Void> unlock(ReactiveLock.Waiter waiter,
 @Nullable
 String extraDbg,
 boolean removeFromWaiters)

debugAsSingleThreaded

public boolean debugAsSingleThreaded()

isLocked

public boolean isLocked()