coroutine: add Coroutine::AsyncQueue and immediate evaluation support in LeafAwaitable - #46885

Merged

botengyao merged 40 commits into

envoyproxy:mainfrom

penguingao:coroutine_async_queue_jetski

Aug 27, 2026

Commits on Aug 22, 2026

coroutine: add AsyncQueue and immediate evaluation support in LeafAwaitable
penguingao
committed
cd8f566
coroutine: bypass capacity check during direct push/pop handoff in AsyncQueue
penguingao
committed
6b8b4ec
coroutine: implement global FIFO capacity waitlist and fix capacity sharing issues in AsyncQueue
penguingao
committed
58146ad
test: streamline coroutine async queue test suite with fixture helpers
penguingao
committed
1b43a77
add some comments
penguingao
committed
b24bb14
coverage
penguingao
committed
03010bc
fix LeafAwaitable cancellation re-entrant problem
penguingao
committed
a77e7f6
safer close() and destructor reentrance protection
penguingao
committed
6b20f09
close() should cancel capacity request first too
penguingao
committed
b3148f2
defense in depth on onCapacityGranted callback
penguingao
committed
dc78372
capture size
penguingao
committed
4ec1e32
format
penguingao
committed
dc3bd3b
create closeInternal() to share between ~AsyncQueue and close()
penguingao
committed
f730914
fix removePushWaiter during closure race
penguingao
committed
0388a3c
cancel after remove
penguingao
committed
57d001e

Commits on Aug 23, 2026

coroutine: implement AsyncQueue and SharedCapacity using AsyncEvent
penguingao
committed
2880839
update design invariant documentation; use status macros in places where appropriate
penguingao
committed
79a4fa2
format
penguingao
committed
8d4bab2

Commits on Aug 24, 2026

async_queue with any_of
penguingao
committed
9aa181b
coroutine: add Semaphore primitive
penguingao
committed
03b9b12
coroutine: integrate Semaphore into AsyncQueue with push-pop rendezvous
penguingao
committed
70b4d1c

Commits on Aug 25, 2026

documentation and some defense in depth code
penguingao
committed
beabd08
remove async_event that's now unused
penguingao
committed
d9550bf
Merge branch 'shared_capacity_async_queue' into coroutine_async_queue_jetski
penguingao
committed
58e7141
coroutine: remove unused any_of primitive
penguingao
committed
b572f68
coroutine: remove redundant std::move on return in Semaphore
penguingao
committed
565b679
fix bug where order is violated in tryPush
penguingao
committed
7a9abb9
Revert "fix bug where order is violated in tryPush"
penguingao
committed
f2b2076
coroutine: preserve caller item on tryPush failure with forwarding references
penguingao
committed
5c1680f
coverage, and optimizations
penguingao
committed
1195813
coroutine: fix ASan stack-use-after-scope and shared_ptr lifetime in tests
penguingao
committed
e0807e2
test refactoring
penguingao
committed
550f8c4
spell; move semantics
penguingao
committed
b5096ef
remove unused move constructors from LeafAwaitable; make Semaphore::release private
penguingao
committed
b49e093
remove unnecessary assertion
penguingao
committed
da12877
add over-sized item documentation; rename test to reflect contract
penguingao
committed
e2ea67c
spelling
penguingao
committed
47d98be
remove SelfMoveAssignmentIsSafe test - self move is discouraged by GCC
penguingao
committed
ae66330
kick CI
penguingao
committed
5e13491

Commits on Aug 27, 2026

add documentation of default bound of AsyncQueue, and general guidance of the size
penguingao
committed
04c72db