Prelude / BPlusTree / AtomicCounter

AtomicCounter

enum AtomicCounter[_: Eff]Source

case AtomicCounter(java.util.concurrent.atomic.LongAdder)

Type of thread-safe Int32 counters.

A LongAdder is used as AtomicInteger/AtomicLong appeared to perform badly under high contention.

Type of thread-safe Int32 counters, and its functions.

Definitions

def get(counter: AtomicCounter[r]): Int32 \ r§ Source

Returns the current state of counter.

def increment(counter: AtomicCounter[r]): Unit \ r§ Source

Increments counter by 1.

def mkCounter(_: Region[r], initialValue: Int32): AtomicCounter[r] \ r§ Source

Returns a fresh counter with initialized to initialVal.