Module canal::mpmc [] [src]

A multi-producer, multi-consumer channel implementation.

Structs

LockFreeQueue

A lock-free queue that is thread-safe for multiple producers and multiple consumers.

MutexLinkedList

A mutex-locked List that is safe for push/pop on multiple threads.

Receiver

The receiving-half of the mpmc channel.

Sender

The sending-half of the mpmc channel.

Enums

Failure

Failure modes for receiving on the port.

Functions

mpmc_channel

Create a channel pair using a lock-free queue with specified capacity.