Module tikv_util::mpsc [−][src]
This module provides an implementation of mpsc channel based on crossbeam_channel. Comparing to the crossbeam_channel, this implementation supports closed detection and try operations.
Modules
batch |
Structs
LooseBoundedSender | A sender of channel that limits the maximun pending messages count loosely. |
Receiver | The receive end of a channel. |
Sender | A sender that can be closed. |
State |
Constants
CHECK_INTERVAL |
Functions
bounded | Create a bounded channel. |
loose_bounded | Create a loosely bounded channel with the given capacity. |
unbounded | Create an unbounded channel. |