-
async-channel
Async multi-producer multi-consumer channel
-
flume
A blazingly fast multi-producer channel
-
futures-channel
Channels for asynchronous communication using futures-rs
-
kanal
The fast sync and async channel that Rust deserves
-
thingbuf
I'm at the buffer pool. I'm at the MPSC channel. I'm at the combination MPSC channel and buffer pool.
-
concurrent-queue
Concurrent multi-producer multi-consumer queue
-
egui_inbox
send messages to egui views from async functions, callbacks, etc. without having to use interior mutability.
-
loole
A safe async/sync multi-producer, multi-consumer channel
-
nexus-queue
High-performance lock-free SPSC and MPSC queues for low-latency systems
-
nexus-logbuf
Lock-free SPSC and MPSC byte ring buffers for logging and archival
-
wasm_safe_thread
Cross-platform std::thread + std::sync replacement for native and wasm32
-
tachyonix
A very fast asynchronous, multi-producer, single-consumer bounded channel
-
linch
In development
-
spawned-rt
Spawned Runtime
-
ironsbe-channel
High-performance channel abstractions for IronSBE messaging
-
swap-buffer-queue
A buffering MPSC queue
-
moire
Runtime graph instrumentation for Tokio-based Rust systems
-
may_queue
May's internal queue library
-
fory-rpc-streaming
Streaming RPC protocol for tarpc-fory — server, client, and bidirectional streaming
-
tsyncp
Async channel APIs (mpsc, broadcast, barrier, etc) over TCP for message-passing
-
scroll-ring
An MPSC overwriting ring buffer tuned for character data scrollback
-
apis
Reactive, session-oriented, asynchronous process-calculus framework
-
expman
Core logic and storage engine for expman
-
kanal-plus
Fork of kanal with extra features (drain_into_blocking, into_stream)
-
rbuffer
Lock-free fixed-size SPSC and MPSC ring buffers for low-latency messaging
-
bmrng
async MPSC request-response channel for Tokio
-
theta-flume
A blazingly fast multi-producer channel
-
re_quota_channel
A channel that applies backpressure based on byte size
-
hermes-broker-server
gRPC server for the Hermes message broker
-
unbounded-spsc
An unbounded spsc queue built from
bounded_spsc_queues -
channels-rs
low latency channels for inter-thread messaging
-
theta-sync
A high-performance no_std MPSC channel with full Tokio compatibility
-
atrg-stream
Jetstream consumer wiring for at-rust-go
-
mpsc
mpsc channel
-
data-courier
Async Rust framework for composable data pipelines
-
tower-actor
A
towermiddleware that creates aServiceby passing messages to an actor -
moduvex-runtime
Custom async runtime for the Moduvex framework — epoll/kqueue/IOCP, hybrid threading
-
notbot
Matrix chatbot, primarily used around the Warsaw Hackerspace channels and spaces
-
burstq
A multi-producer, multi-consumer channel that supports sending or receiving multiple values in a single operation
-
sod-mpsc
Service Oriented Design - Multi Producer Single Consumer
-
epics-base-rs
Pure Rust EPICS IOC core — record system, database, iocsh, calc engine
-
yatch
🦇 Experimental batching on
mpscchannels withVecDequein Rust -
xiaoyong-channels
Collection of channel primitives for sync and async contexts (both Sync and !Sync)
-
hopper
an unbounded mpsc with bounded memory
-
rsticulum-interface
Network interfaces: KISS, serial, TCP, I2P framing
-
kstool-helper-generator
A macro help user create mpsc communications and other
-
conqueue
multi-producer, single-consumer queue (MPSC)
-
mqd-engine
Async ingest, snapshot-isolated store, point-in-time query, and domain operators over Arrow
-
arrow-message
implements a way to define messages according to the Arrow format in both Rust and Python
-
smpsc
Wrappers for tokio's mpsc channels which implement Stream and Sink
-
walchan
A persistent mpsc-like channel backed by a write-ahead log (WAL)
-
magic-orb
thread-safe, overwrite, heap-stored, fix-sized, locking Ring buffer
-
relay_channel
A single-producer, single-consumer channel where the sender waits for the receiver to receive the message before returning
-
ductile
A channel implementation that allows both local in-memory channels and remote TCP-based channels with the same interface
-
kora-embedded
Embeddable library mode for Kōra — use as a direct API without a network layer
-
talaria
A high performance, cyclic message passing library
-
mpsc_requests
mpsc channels but with a response
-
aeronet_channel
In-memory MPSC channel IO layer implementation for
aeronet -
any-mpsc
An mpsc that allows arbitrary types to be passed through
-
uchan
Multi-producer single-consumer channel for message passing
-
async-priority-channel
An async channel where pending messages are delivered in order of priority
-
worker-pool
handle a set of worker threads, which need to communicate back their result to the main thread
-
pezsc-utils
I/O for Bizinikiwi runtimes
-
dir_watcher
monitoring directories for changes
-
stray
A freedesktop StatusNotifierWatcher implementation
-
simple-channels
educational implementation of channels in Rust
-
streambed-patterns
Patterns for working with streambed
-
hive_pubsub
Generic Pub/Sub library
-
tokio-stdin-stdout
Thread- and future::sync::mpsc-based AsyncRead/AsyncWrite stdin/stdout with little buffering
-
mpmc-scheduler
multi-mpmc, cancellable, scheduler with rate limiting
-
way
Fast Async Channel With no-std Support and Alternative Sync API
-
qanat
Lock-free channels specially written for asynchronous contexts
-
message_worker
Message Worker is a low-ish level library for Rust for the creation of event-listeners using futures and streams. Notably MW supports non-sync and non-send (i.e. non-thread-safe) contexts within listeners.
-
request-channel
Async MPSC request-reponse channel
-
workerpool-rs
workerpool for rust
-
bufchan
buffered MPSC channel
-
key-message-channel
Multi-producer single-consumer queue capable of queuing messages by message key
-
task-collection
Types for managing and waiting on groups of tasks
-
ez-api
MPSC TCP Data Exchange Limited to the Rust Standard Library
-
lock-free-multi-producer-single-consumer-ring-buffer
A lock-free, multi-producer, single-consumer (MPSC) ring buffer. Optimized for sending and receiving 'bursts' of messages. Can also be used as a ring queue. It is a Rust port of Mindaugas Rasiukevicius's ringbuf.
-
pmpmc
A priority multi producer multi consumer channel
-
sc-utils
I/O for Substrate runtimes
-
vil_multi_agent
VIL Multi-Agent System — compile agent graphs to state machines with typed inter-agent channels
-
lf-queue
A lock-free multi-producer multi-consumer unbounded queue
-
kik_sync_service
A synchronous threading worker channel for generating the results you want with the data you need
-
sender-sink
classes for working with tokio UnboundedSender and the Sink trait
-
channelmap
A DashMap wrapper over Tokio channels
-
tpool
So simple thread pool
-
tokio-bichannel
Bidirectional tokio::sync::mpsc channel
-
channel_pipes
Perform operations on broadcast queues
-
simple-tokio-watchdog
Pretty simple but bulletproof watchdog actor
-
meowtex
Saddened by the feeling that Rust multitasking types are not puppy-/kittycoded enough for you? Then this crate is for you!
-
venom_log
Rust async log High-performance asynchronous logging
-
intuition
Gain intuition about the goings-on of your multithreaded/multicomponent programs
-
unsync_channel
!Send/!Sync channels for Rust
-
mrsc
mpsc with requests
-
sharify
Back types with shared memory and send them cheaply between processes
-
gts-transport
Gts transport
-
tokio-channels-console
Like tokio-console, but for channels
-
driver_async
async backend for
btle,bluetooth_meshandusbwcrates -
jackiechan
Bounded mpsc channel optimized for lazy bulk operations
-
simple_pubsub
pubsub use dashmap and mpsc channel
-
transformable_channels
Rust channels are a convenient abstraction, but for many uses cases, they miss high-level transformations such as
map,filter, … . This crate introduces them. -
libmcs
A MCS Lock Library
-
promissory
One-shot value exhange between threads
-
periodic_do
Run task periodically until it reaches a terminal state
-
riffy
An unbounded, wait-free, multi-producer-single-consumer queue
-
navvy
MPSC Channel broker allowing channels of different types to be stored in a single data structure
-
arcana-base-server
help create your own arcana activation server
Try searching with DuckDuckGo.