wow-spring-boot-starter/me.ahoo.wow.spring.boot.starter/DispatchProperties

DispatchProperties

class DispatchProperties(var workers: Int = KeyedExecutor.DEFAULT_WORKERS, var maxInFlight: Int = KeyedExecutor.DEFAULT_MAX_IN_FLIGHT, var throughput: Int = KeyedExecutor.DEFAULT_THROUGHPUT, var spin: Duration = KeyedExecutor.DEFAULT_SPIN)

The runtime's KeyedExecutor (wow.dispatch.*): the worker threads every dispatcher shares, and how many unfinished messages one receiver (one per dispatcher and bounded context) holds before it stops requesting more from its transport.

Constructors

DispatchProperties

constructor(workers: Int = KeyedExecutor.DEFAULT_WORKERS, maxInFlight: Int = KeyedExecutor.DEFAULT_MAX_IN_FLIGHT, throughput: Int = KeyedExecutor.DEFAULT_THROUGHPUT, spin: Duration = KeyedExecutor.DEFAULT_SPIN)

Properties

maxInFlight

var maxInFlight: Int

spin

var spin: Duration

How long a worker that ran out of messages spins before it parks (see KeyedExecutor.spin for when it pays and its CPU cost), at most 1 ms; the default 0 parks at once (no spin). Give a unit suffix (20us): a bare number is read as milliseconds.

throughput

var throughput: Int

workers

var workers: Int