BoundedQueue

@forge/monorepo

---

@forge/monorepo / backend/src / BoundedQueue

Type Alias: BoundedQueue

BoundedQueue = object

Defined in: backend/src/loadtest/harness.ts:88

Properties

dispatcher

readonly dispatcher: JobDispatcher

Defined in: backend/src/loadtest/harness.ts:89

Methods

consumerFor()

consumerFor(): JobConsumer

Defined in: backend/src/loadtest/harness.ts:98

A fresh consumer per worker, not one shared object.

JobConsumer.stop() has no handle to say which worker is stopping, so a shared consumer's stop had to clear every registration — which meant killing one worker silently stopped all three. The worker-kill injection then hung forever waiting for a drain that could never happen, produced no output at all, and it took a process listing to find. Each worker gets its own view, closing over its own slot.

Returns

JobConsumer

---

depth()

depth(): number

Defined in: backend/src/loadtest/harness.ts:99

Returns

number

---

drained()

drained(): Promise<void>

Defined in: backend/src/loadtest/harness.ts:104

Returns

Promise<void>

---

peakDepth()

peakDepth(): number

Defined in: backend/src/loadtest/harness.ts:100

Returns

number

---

refused()

refused(): number

Defined in: backend/src/loadtest/harness.ts:101

Returns

number

---

retried()

retried(): number

Defined in: backend/src/loadtest/harness.ts:103

Jobs handed to a worker more than once. A pass that needed retries is not a clean first-attempt pass.

Returns

number