Crate rc_event_queue

Concurrent FIFO event queue / message queue. Multi consumer. Each consumer receive all messages. Lock-free reading. Write under lock (for mpmc version). Write lock does not block read.

Linked list of chunks (C++ std::deque -like). Each chunk have “read counter”. When “read counter” reach readers count - it is safe to drop chunk. Chunk considered read, when Reader reach its end. See doc/principle-of-operation.md.

EventQueue live, until EventReaders live. In order to completely drop EventQueue - drop all associated EventReaders.

Features

• double_buffering : Reuse biggest freed chunk.

Modules

• mpmc
  Multi-producer multi-consumer.
• prelude
• spmc
  Single-producer multi-consumer.

Enums

• CleanupMode
  This way you can control when chunk’s memory deallocation happens. In addition, some operations may cause deallocations as well.

Traits

• LendingIterator
  This should be rust GAT iterator. But it does not exists yet.