Implementation of event queue using System.Threading.Channels
$ dotnet add package MetaFac.Threading.ChannelsA collection of inter-thread coordination types with implementations based on System.Threading.Channels and LMAX Disruptor.
A multi-writer single-reader queue of events where events are IExecutable. Execute() is called for each event.
A multi-writer single-reader queue of events where that are passed to a provided implementation of IEventHandler.
A multi-writer single-reader queue of events. Each event and current state are passed to a provided implementation of IStateEventHandler which returns updated state.
A thread-safe counter that signals each time zero is crossed (in either direction) via a completion task. Can be used in hierarchies of counters.
A multi-writer single-reader queue of synchronous or asynchronous tasks where that is called for each event.