Commit 4e675d1
committed
feat: implement true lock-free bounded queues with committed flags
Replace ordered commit pattern (blocking while loops) with per-slot
committed flags for lock-free progress guarantees:
- Mupsic (MPSC): Add committed flags array, producers CAS reservedTail
and mark committed without blocking. Consumer checks committed before
reading. Uses head/tail distance for fullness to prevent wraparound.
- Sipmuc (SPMC): Add committed flags array, consumers CAS reservedHead
and check committed before reading. Producer marks committed after
writing. Uses committed flags for fullness check.
- Mupmuc (MPMC): Add MupmucProducer type that uses reservedHead for
fullness check instead of head. This prevents livelock when consumers
complete out-of-order causing head to lag behind reservedHead.
Key changes:
- committed: array[N, Atomic[bool]] per-slot flags signal data readiness
- Producers set committed[slot]=true after writing
- Consumers check committed[slot] before reading, clear after consuming
- Multi-consumer fullness uses reservedHead not head (avoids livelock)
- All threaded tests pass under high contention
This fixes race conditions where:
1. Ordered wait caused obstruction-free (not lock-free) behavior
2. Wraparound allowed producers to overwrite uncommitted slots
3. Stale head caused producers to think queue was full1 parent d2a9e53 commit 4e675d1
27 files changed
Lines changed: 1455 additions & 1136 deletions
File tree
- examples
- src/lockfreequeues
- tests
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
2 | | - | |
3 | | - | |
4 | | - | |
5 | | - | |
6 | | - | |
7 | 1 | | |
8 | 2 | | |
9 | 3 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
2 | | - | |
3 | | - | |
4 | | - | |
5 | | - | |
6 | | - | |
7 | 1 | | |
8 | 2 | | |
9 | 3 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
2 | | - | |
3 | | - | |
4 | | - | |
5 | | - | |
6 | | - | |
7 | 1 | | |
8 | 2 | | |
9 | 3 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
2 | | - | |
3 | | - | |
4 | | - | |
5 | | - | |
6 | | - | |
7 | 1 | | |
8 | 2 | | |
9 | 3 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
2 | | - | |
3 | | - | |
4 | | - | |
5 | | - | |
6 | | - | |
7 | 1 | | |
8 | 2 | | |
9 | 3 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
2 | | - | |
3 | | - | |
4 | | - | |
5 | | - | |
6 | | - | |
7 | 1 | | |
8 | 2 | | |
9 | 3 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | | - | |
2 | | - | |
3 | | - | |
4 | | - | |
5 | | - | |
6 | | - | |
7 | 1 | | |
8 | 2 | | |
9 | 3 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
48 | 48 | | |
49 | 49 | | |
50 | 50 | | |
51 | | - | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
52 | 54 | | |
53 | 55 | | |
54 | 56 | | |
| |||
63 | 65 | | |
64 | 66 | | |
65 | 67 | | |
| 68 | + | |
66 | 69 | | |
67 | 70 | | |
68 | 71 | | |
| |||
85 | 88 | | |
86 | 89 | | |
87 | 90 | | |
88 | | - | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
89 | 94 | | |
90 | 95 | | |
91 | 96 | | |
| |||
0 commit comments