BoundedBatchArbiter

constructor(batchSize: Int, maxWait: Double)(source)

Parameters

batchSize

how many waiting people open a turn

maxWait

how long the first of them will wait before a turn opens regardless