hanzoai/pubsub-go
2
0
Fork 0
mirror of https://github.com/hanzoai/pubsub-go.git synced 2026-10-30 18:23:30 +00:00
Code Issues Packages Projects Releases Wiki Activity
Files
main
pubsub-go/internal/syncx
T
History
Piotr PiotrowskiandGitHub e1f12bbf4b [FIXED] Deadlock when accessing subscriptions map on consumer (#1671) 
This fixes an issue where a deadlock could occur when calling `Stop()` or
`Drain()` on `ConsumeContext` or `MessagesContext` and then calling `Consume` or
`Messages` immediately.
Switched to using a type-safe implementation of `sync.Map` for subscriptions map
instead of locking the whole consumer state.
Additionally, changed the type of atomic flags from `uint32` to `atomic.UInt32`
to avoid accidental non-atomic reads/writes.

Signed-off-by: Piotr Piotrowski <[email protected]>

---------

Signed-off-by: Piotr Piotrowski <[email protected]>
2024-07-25 10:29:43 +02:00
..
map_test.go
[FIXED] Deadlock when accessing subscriptions map on consumer (#1671)
2024-07-25 10:29:43 +02:00
map.go
[FIXED] Deadlock when accessing subscriptions map on consumer (#1671)
2024-07-25 10:29:43 +02:00