PriorityChansConverger: Read single output from an array of inputs - channels with priorities
Abbreviation for the
PriorityChansConverger is PCC.
STM.TChan, extended with capacity control.
Wrapped into IO version is also available.
When user reads from the PCC, the choice is made - from which channel to read. System selects a nonempty channel, whose (CurrentPriority, StartPriority) tuple is max. The side effect of the channel selection is it's CurrentPriority decrease by one, if it's value becomes less than one, then the CurrentPriority is set to StartPriority.
For the main API interface:
The realization probably isn't
very fast and isn't good at memory economy, since it uses fresh high
level primitive - STM. It wasn't intended to be used
with millions of channels. But it's max throughput comparing to the
Chan throughput is to be estimated (will do it in some
|Dependencies||base (==4.*), containers, stm [details]|
|Copyright||Copyright (c) 2009-2010 Andrejs Sisojevs|
|Author||Andrejs Sisojevs <email@example.com>|
|Maintainer||Andrejs Sisojevs <firstname.lastname@example.org>|
|Uploaded||by AndreySisoyev at Sun Jan 3 07:02:58 UTC 2010|
|Downloads||878 total (24 in the last 30 days)|
|Rating||(no votes yet) [estimated by rule of succession]|
Docs uploaded by user
Build status unknown [no reports yet]
For package maintainers and hackage trustees