Add WorkQueue<T> with MPSC and linked-queue backings - #12313

Open

dougqh wants to merge 49 commits into

dougqh/apmlp-1642-queue-api

Commits on Aug 27, 2026

Add Queue<T> admission and consumption API

dougqh
and
claude
committed
6fdbe96
Add MPSC and linked-queue backings behind Queue<T>

dougqh
and
claude
committed
76eeeb1
Prefix Queue factory methods with create

dougqh
and
claude
committed
cbb32c3
Rename Queue to WorkQueue and split its factories from Queues

dougqh
and
claude
committed
c1ce00a
Drop BatchProducer and put() until SCA needs them

dougqh
and
claude
committed
0f009cf
Add a single-element RetryQueue.retry overload

dougqh
and
claude
committed
edbf5a5
Let a consumer failure propagate when no RetryStrategy is given

dougqh
and
claude
committed
09dcab0
Add tryReserve as an escape hatch for callers that cannot use a Producer

dougqh
and
claude
committed
f3c1a18
Let the linked backing reserve capacity without holding a position

dougqh
and
claude
committed
8fd67a0
Bound the linked backing with a permit counter

dougqh
and
claude
committed
454c309
Describe linked-backing reservations, which are no longer unsupported

dougqh
and
claude
committed
7f627fd
Add a batched process that takes an item limit

dougqh
and
claude
committed
061ce46
Let a producer take a second context

dougqh
and
claude
committed
19d8d02
Bound every backing with the same permit counter

dougqh
and
claude
committed
23a7b1f
Answer a refused claim with a reservation instead of null

dougqh
and
claude
committed
a664754
Say which admission form to reach for, and stop describing a stall

dougqh
and
claude
committed
a9f6c43
Mark the producer forms as strategies

dougqh
and
claude
committed
d47180b
Answer the review on the admission and consumption edges

dougqh
and
claude
committed
2741689
Name the failure-handling forms apart from plain process

dougqh
and
claude
committed
e3594a5

Commits on Aug 28, 2026

Benchmark admission against both backings

dougqh
and
claude
committed
833ca7f
Build a refusal instead of sharing one

dougqh
and
claude
committed
adabbda
Hand the reservation its queue instead of hiding it

dougqh
and
claude
committed
ed38899
Let the queue walk a batch and transform as it goes
dougqh
committed
d155316
Return how many a batch admitted rather than which were refused
dougqh
committed
e5cc78b
Let a batch caller say where its refusals go
dougqh
committed
7098438

Commits on Aug 29, 2026

Say what a null means once, instead of five times differently

dougqh
and
claude
committed
58520ce
Count a lost item once, not once per step that lost it

dougqh
and
claude
committed
bc7b7bc
Stop claiming shutdown is atomic, because it is not

dougqh
and
claude
committed
0497ad5
Benchmark admission with more than one thread admitting

dougqh
and
claude
committed
9e10f24
Own the drain thread so the contended arm survives a thread-count override

dougqh
and
claude
committed
c631f94
Refuse with a load, and let the counter carry the closed state

dougqh
and
claude
committed
51fb1c3
Record what the read bought at the boundary

dougqh
and
claude
committed
c8cc491

Commits on Aug 31, 2026

Claim a batch's places in one go, clamped to what is there

dougqh
and
claude
committed
79b3c40
Price the queue against what callers write instead

dougqh
and
claude
committed
45a643d
Back the multi-consumer queue with an array ring

dougqh
and
claude
committed
932653d
Measure the third-backing cliff instead of asserting it

dougqh
and
claude
committed
74fb505
Give the place back when a backing refuses a filled element

dougqh
and
claude
committed
0b27ed2
Measure what the retry lease actually costs

dougqh
and
claude
committed
4bba350
Price the strategy binding, not just the lease

dougqh
and
claude
committed
c8500b4
Finish the strategy binding matrix with the exact-typed field

dougqh
and
claude
committed
95005d0
Say which hand-rolled failures this API deletes

dougqh
and
claude
committed
43add18

Commits on Sep 1, 2026

Let the caller's own return value be the record of a refusal

dougqh
and
claude
committed
888919f
Keep size() inside the bound it reports against

dougqh
and
claude
committed
adf58b6
Say that a retried item may not be null

dougqh
and
claude
committed
810fc2a
Stop claiming the MPMC ring's poll reports a false empty

dougqh
and
claude
committed
360ba79
Give MaxRetries the number of retries its name promises

dougqh
and
claude
committed
a0cd339
Point at the JCTools docs instead of re-teaching them

dougqh
and
claude
committed
5fc2d2d
Say on the producer forms what a null return means

dougqh
and
claude
committed
77144ca
Merge branch 'master' into dougqh/apmlp-1642-queue-api
dougqh
authored
663192b