broadcast-chan: Closable, fair, single-wakeup channel type that avoids 0 reader space leaks.
WARNING: While the code in this library should be fairly stable and production, the API is something I'm still working on. API changes will follow the PVP, but expect breaking API changes in future versions!
A closable, fair, single-wakeup channel that avoids the 0 reader space leak
Control.Concurrent.Chan from base suffers from.
Chan type from
Control.Concurrent.Chan consists of both a read
and write end combined into a single value. This means there is always at
least 1 read end for a
Chan, which keeps any values written to it alive.
This is a problem for applications/libraries that want to have a channel
that can have zero listeners.
Suppose we have an library that produces events and we want to let users
register to receive events. If we use a channel and write all events to it,
we would like to drop and garbage collect any events that take place when
there are 0 listeners. The always present read end of
Chan from base
makes this impossible. We end up with a
Chan that forever accumulates
more and more events that will never get removed, resulting in a memory
BroadcastChan splits channels into separate read and write ends. Any
message written to a a channel with no existing read end is immediately
dropped so it can be garbage collected. Once a read end is created, all
messages written to the channel will be accessible to that read end.
Once all read ends for a channel have disappeared and been garbage collected, the channel will return to dropping messages as soon as they are written.
BroadcastChanhas no 0 reader space leak,
BroadcastChanhas comparable or better performance.
Why should I use BroadcastChan over various (closable) STM channels?
BroadcastChanperforms better under contention.
[Skip to Readme]
|Versions||0.1.0, 0.1.1, 0.2.0|
|Dependencies||base (>=4.6 && <5), unliftio-core (>=0.1.1 && <0.2) [details]|
|Copyright||Copyright © 2014-2018 Merijn Verstraaten|
|Maintainer||Merijn Verstraaten <email@example.com>|
|Source repo||head: git clone ssh://github.com:merijn/broadcast-chan.git
head: hg clone https://bitbucket.org/merijnv/broadcast-chan
|Uploaded||by MerijnVerstraaten at Thu Sep 20 14:00:51 UTC 2018|
|Distributions||LTSHaskell:0.1.1, NixOS:0.1.1, Stackage:0.2.0|
|Downloads||1312 total (45 in the last 30 days)|
|Rating||(no votes yet) [estimated by rule of succession]|
|Status||Docs uploaded by user
Build status unknown [no reports yet]
Hackage Matrix CI
Benchmarks synchronisation primitives used in main benchmark.
Run benchmarks with threaded backend.
Use -f <flag> to enable a flag, or -f -<flag> to disable that flag. More info
For package maintainers and hackage trustees