feat(mpsc): add fair capacity reservations to bounded channels - #291

Merged

tisonkun merged 34 commits into

apache:mainfrom

tisonkun:codex/bounded-reserve-publish

Sep 9, 2026

Commits on Sep 8, 2026

Commits on Sep 9, 2026

refactor(mpsc): separate bounded capacity and ring publication
tisonkun
committed
d085334
test(mpsc): distinguish task and external receiver benchmarks
tisonkun
committed
7ad35ad
fixup
tisonkun
committed
31c64cc
test(mpsc): remove Kanal from ecosystem benchmarks
tisonkun
committed
df2b96a
refactor(mpsc): back bounded storage with std sync_channel
tisonkun
committed
04d2f08
Revert "refactor(mpsc): back bounded storage with std sync_channel"
tisonkun
committed
9cb5d1e
fix(mpsc): reject oversized bounded capacity up front
tisonkun
committed
7282b14
perf(mpsc): pack bounded semaphore state into one atomic
tisonkun
committed
a8cf749
perf(mpsc): skip the receiver wake when it is not parked
tisonkun
committed
b2c4ff6
perf(mpsc): count zero-sized bounded messages atomically
tisonkun
committed
24ae4c8
Revert "perf(mpsc): skip the receiver wake when it is not parked"
tisonkun
committed
03c2336
test(mpsc): pin sample sizes for nanosecond-scale benches
tisonkun
committed
bcd7129
docs: note bounded MPSC throughput improvements in the changelog
tisonkun
committed
385876b
refactor(mpsc): drop the bounded allocation pre-check
tisonkun
committed
9febe2a
perf(mpsc): restore the receiver waker state with a plain store
tisonkun
committed
ee540c8
refactor(mpsc): give zero-sized bounded storage its own type
tisonkun
committed
afb7c7f
refactor(mpsc): encode bounded semaphore sentinels as values, not bits
tisonkun
committed
99373fe
perf(mpsc): drop cache padding from the receiver waker
tisonkun
committed
682bfab
refactor(mpsc): organize the bounded channel by endpoint
tisonkun
committed
aec619f
refactor(mpsc): split bounded buffer storage by message size
tisonkun
committed
8070c87
test(mpsc): inline the bounded buffer tests
tisonkun
committed
4c922a9
fixup
tisonkun
committed
7093466
fixup
tisonkun
committed
7707e02
fix(mpsc): preserve wakeups and capacity ownership
tisonkun
committed
25775fb
refactor(mpsc): unify bounded message storage
tisonkun
committed
c5b75ee
refactor(mpsc): simplify publication and receiver wakeups
tisonkun
committed
22c85e4
refactor(mpsc): use one mutex for bounded channels
tisonkun
committed
898a3c4
refactor(mpsc): clarify bounded state and capacity limits
tisonkun
committed
010a334
docs(mpsc): clarify reservation errors and method links
tisonkun
committed
824bac1
refactor(mpsc): simplify bounded send and wake paths
tisonkun
committed
6cb4d6b

Navigation Menu

Uh oh!

feat(mpsc): add fair capacity reservations to bounded channels - #291

feat(mpsc): add fair capacity reservations to bounded channels#291
tisonkun merged 34 commits into
apache:mainfrom
tisonkun:codex/bounded-reserve-publish

Commits on Sep 8, 2026

feat(mpsc): add bounded permits with sequenced publication

test(mpsc): benchmark reservations and inline bounded messages

chore: remove the unused internal atomic waker

refactor(mpsc): simplify bounded state under one mutex

Commits on Sep 9, 2026

refactor(mpsc): separate bounded capacity and ring publication

test(mpsc): distinguish task and external receiver benchmarks

fixup

test(mpsc): remove Kanal from ecosystem benchmarks

refactor(mpsc): back bounded storage with std sync_channel

Revert "refactor(mpsc): back bounded storage with std sync_channel"

fix(mpsc): reject oversized bounded capacity up front

perf(mpsc): pack bounded semaphore state into one atomic

perf(mpsc): skip the receiver wake when it is not parked

perf(mpsc): count zero-sized bounded messages atomically

Revert "perf(mpsc): skip the receiver wake when it is not parked"

test(mpsc): pin sample sizes for nanosecond-scale benches

docs: note bounded MPSC throughput improvements in the changelog

refactor(mpsc): drop the bounded allocation pre-check

perf(mpsc): restore the receiver waker state with a plain store

refactor(mpsc): give zero-sized bounded storage its own type

refactor(mpsc): encode bounded semaphore sentinels as values, not bits

perf(mpsc): drop cache padding from the receiver waker

refactor(mpsc): organize the bounded channel by endpoint

refactor(mpsc): split bounded buffer storage by message size

test(mpsc): inline the bounded buffer tests

fixup

fixup

fix(mpsc): preserve wakeups and capacity ownership

refactor(mpsc): unify bounded message storage

refactor(mpsc): simplify publication and receiver wakeups

refactor(mpsc): use one mutex for bounded channels

refactor(mpsc): clarify bounded state and capacity limits

docs(mpsc): clarify reservation errors and method links

refactor(mpsc): simplify bounded send and wake paths