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.