Repository navigation

Add WorkQueue<T> with MPSC and MPMC array backings (perf toolbox) - #12313

Open

dougqh wants to merge 69 commits into

masterfrom

dougqh/apmlp-1642-queue-api

Open

Add WorkQueue<T> with MPSC and MPMC array backings (perf toolbox)#12313
dougqh wants to merge 69 commits into
masterfrom
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
Commits on Oct 7, 2026
- Merge branch 'master' into dougqh/apmlp-1642-queue-api
  dougqh
  authored
  dd9ceb8
Commits on Oct 22, 2026
- Remove the MPMC store retry that can never run
  
  dougqh
  and
  claude
  committed
  f042f49
- Confine a reservation to the thread that reserved it
  
  dougqh
  and
  claude
  committed
  744707f
- Mark function-object parameters @Nonnull instead of checking them
  
  dougqh
  and
  claude
  committed
  07a0fe1
- Stop claiming a refused reservation counts its drop
  
  dougqh
  and
  claude
  committed
  8ff0cc0
- Create the retry-count strategy through RetryStrategy.maxRetries
  
  dougqh
  and
  claude
  committed
  77a4e72
- Tighten queue Javadoc per review
  
  dougqh
  and
  claude
  committed
  1a50f60
- State the AdmissionBenchmark question the right way round
  
  dougqh
  and
  claude
  committed
  67261e1
- Stop attributing the steady-arm gap to the drain
  
  dougqh
  and
  claude
  committed
  392bbf9
- Point the steady queue's Javadoc at the thread that drains it
  
  dougqh
  and
  claude
  committed
  3edfb22
- Stop describing WorkQueues as counting what they drop
  
  dougqh
  and
  claude
  committed
  cfd560f
- Describe the batch-claim cap as a limit on withheld capacity
  
  dougqh
  and
  claude
  committed
  cf6343f
- Qualify the Producer allocation claim
  
  dougqh
  and
  claude
  committed
  8d8995d
- Say which in-flight work can outlive a shutdown
  
  dougqh
  and
  claude
  committed
  7693aa3
- Reduce the WorkQueue class doc to its contract
  
  dougqh
  and
  claude
  committed
  08b0283
- Price WorkQueue against the ring's own claim-before-build
  
  dougqh
  and
  claude
  committed
  bf786e9
Commits on Oct 26, 2026
- Rename ThirdBackingWorkQueue to MegamorphicCallSiteWorkQueue
  
  dougqh
  and
  claude
  committed
  47038d9
- Point Queues' class doc at WorkQueues
  
  dougqh
  and
  claude
  committed
  c2ae3e2
Commits on Oct 30, 2026
- Bring WorkQueueContractTest's reservation comments up to date
  
  dougqh
  and
  claude
  committed
  a4bef25
- Cover WorkQueue's contextual consumers and batch release paths
  
  dougqh
  and
  claude
  committed
  9fc6cb7

Commits

Commits on Aug 27, 2026

Commits on Aug 28, 2026

Commits on Aug 29, 2026

Commits on Aug 31, 2026

Commits on Sep 1, 2026

Commits on Oct 7, 2026

Commits on Oct 22, 2026

Commits on Oct 26, 2026

Commits on Oct 30, 2026