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

Class BlockingWaitGroup

java.lang.Object

com.couchbase.client.core.transaction.util.BlockingWaitGroup

@Internal
public class BlockingWaitGroup
extends Object

Provides locking functionality in line with Go's WaitGroups.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BlockingWaitGroup.TimeoutExceptionFactory
static interface	BlockingWaitGroup.WaitGroupLogger

Constructor Summary

Constructors

Constructor	Description
BlockingWaitGroup(BlockingWaitGroup.TimeoutExceptionFactory timeoutExceptionFactory, BlockingWaitGroup.WaitGroupLogger logger, boolean debugMode)

Method Summary

Modifier and Type	Method	Description
boolean	add(String dbg)
void	await(Duration timeout)
void	closeAndAwait(Duration timeout)
void	done()
boolean	isClosed()
int	waitingCount()

Methods inherited from class java.lang.Object

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

Constructor Details

BlockingWaitGroup

public BlockingWaitGroup(BlockingWaitGroup.TimeoutExceptionFactory timeoutExceptionFactory,
 @Nullable
 BlockingWaitGroup.WaitGroupLogger logger,
 boolean debugMode)

Method Details

waitingCount

public int waitingCount()

add

public boolean add(String dbg)

done

public void done()

await

public void await(Duration timeout)

closeAndAwait

public void closeAndAwait(Duration timeout)

isClosed

public boolean isClosed()