MCPcopy Create free account
hub / github.com/questdb/questdb / then

Method then

core/src/main/java/io/questdb/mp/Barrier.java:53–53  ·  view source on GitHub ↗
(Barrier barrier)

Source from the content-addressed store, hash-verified

51 void setCurrent(long value);
52
53 Barrier then(Barrier barrier);
54}

Callers 15

testCachedAsyncFilterAfterTableTruncateMethod · 0.65
testTwoThreadsSendTwoThreadsReadMethod · 0.65
testConcurrencyMethod · 0.65
testRollingFileWriterBySizeMethod · 0.65
testSpaceInRollEveryMethod · 0.65
mainMethod · 0.65
testUnboundedLatchMethod · 0.65
mainMethod · 0.65
testConcurrentFanOutAndMethod · 0.65
testConcurrentFanOutAsyncOffloadPatternMethod · 0.65
testDoneMemBarrierMethod · 0.65
testFanOutChainMethod · 0.65

Implementers 2

OpenBarriercore/src/main/java/io/questdb/mp/OpenB
FanOutcore/src/main/java/io/questdb/mp/FanOu

Calls

no outgoing calls

Tested by 15

testCachedAsyncFilterAfterTableTruncateMethod · 0.52
testTwoThreadsSendTwoThreadsReadMethod · 0.52
testConcurrencyMethod · 0.52
testRollingFileWriterBySizeMethod · 0.52
testSpaceInRollEveryMethod · 0.52
mainMethod · 0.52
testUnboundedLatchMethod · 0.52
mainMethod · 0.52
testConcurrentFanOutAndMethod · 0.52
testConcurrentFanOutAsyncOffloadPatternMethod · 0.52
testDoneMemBarrierMethod · 0.52
testFanOutChainMethod · 0.52