CATEGORY
Concurrency 3,422 crates
Data as of 2026-07-25 (crates.io database dump, timestamp 2026-07-25T02:00:36Z). Source: crates.io · db-dump.tar.gz · methodology & corrections.
piying_actorsUtility actors for piying36MIT OR Apache-2.0
chenalPerformant channel implementations36MIT OR Apache-2.0
auto-ytdlpDownload videos with yt-dlp automatically. You can even download multiple videos at the same time!36GPL-3.0
reliability-toolkitAsync reliability primitives for Rust: rate limiter, circuit breaker, retry with jitter, bulkhead. Optional audit-stream-py…36MIT
shmfeederA lock-free single-producer, multi-consumer broadcast ring buffer backed by POSIX shared memory.36MIT OR Apache-2.0
polybox-codegenMessage-passing abstractions to make working with channels and actors a more seamless experience36MIT OR Apache-2.0
komadori-rayonMulti-reduction library. Provides a composable, declarative way to reduce in parallel in rayon's style35MIT OR Apache-2.0
inflight-setAcquire many distinct RAII guards keyed by name, allowing only one in-flight guard per key.35MIT
boson-backend-sqliteSQLite QueueBackend adapter for Boson35MIT
lockfree_progress_barA high-performance, lock-free progress bar for parallel Rust applications35MIT
tokio-multi-lockDeadlock-safe concurrent lock acquisition35LGPL-3.0-or-later
sruim-crewaiA high-performance multi-agent orchestration engine written in Rust35MIT
par-validatorA truely parallel field validator engine written on top of ryon, wgpu and rust-key-paths.35MIT
starlangStarlang - Erlang-style concurrency for Rust35MIT OR Apache-2.0
dstate-dactordactor actor hosting for dstate distributed state replication35MIT
sayiir-cloudflareCloudflare Workers WASM bindings for Sayiir workflow engine35MIT
wayFast Async Channel With no-std Support and Alternative Sync API34MIT
boson-backend-postgresPostgreSQL QueueBackend adapter for Boson34MIT
smc_scan_mtlMTL oracle for the Scan model checker.34Apache-2.0
hansaFederation primitive for skeg: local AI agents form trust groups and query across each other's memory.34Apache-2.0
cyclotraceA high-performance, wait-free ring buffer in Rust. Supports SPMC with peek-based semantics instead of destructive consumption.34MIT OR Apache-2.0
fpxA pre-research: Fabric-Pipeline-eXchange, a Rust stream processing exchange framework.34Apache-2.0
axicor-nodeAxicor SNN engine — BSP-lockstep orchestrator, UDP fast-path server, Night Phase daemon34MIT OR Apache-2.0
emqSafe Rust bindings for EmbeddedMQ34Apache-2.0
finitomataFinite state machines with rich lifecycle callbacks, persistence, and supervision34MIT OR Apache-2.0
sevmapA lock-free, eventually consistent, concurrent single-value map.34MIT OR Apache-2.0
reed-solomon-turboFast systematic Reed-Solomon erasure coding over GF(2^8), byte-compatible with klauspost/reedsolomon and the Backblaze matrix…34MIT OR Apache-2.0
avx-parallelZero-dependency parallel library with work stealing, SIMD, lock-free operations, adaptive execution, and memory-efficient…33MIT
messaggeroHigh-performance agent-to-agent communication protocol for Rust. A2A-compatible over HTTP/JSON-RPC with a zero-overhead binary…33MIT OR Apache-2.0
satinLow-overhead parallel iterators33MIT OR Apache-2.0
surt-coreHost-testable SPSC ring transport core for SURT (no_std, no hot-path allocation).33MIT OR Apache-2.0
qmi-macroA variant of ECS where topology matters and makes us happy.32MIT
avx-asyncRevolutionary async runtime - Quantum, Neural Networks, Blockchain, Genetic Algorithms, Zero dependencies32MIT OR Apache-2.0
chrononDeterministic execution kernel with crash-safe replication and exactly-once side effects32MIT OR Apache-2.0
statewatcherA simple, shared state channel where readers are notified of updates, inspired by tokio::watch but for std32MIT OR Apache-2.0
tensor-wasm-execWasmtime + Tokio async execution engine for TensorWasm instances.32Apache-2.0
oxigeo-haHigh availability, disaster recovery, and automatic failover for OxiGeo32Apache-2.0
oxigeo-distributedDistributed processing capabilities for OxiGeo using Apache Arrow Flight32Apache-2.0
prismultiA multi-threaded Rust implementation of a subset of the PRISM model checker.32MIT
polybox-coreMessage-passing abstractions to make working with channels and actors a more seamless experience32MIT OR Apache-2.0
cache233A high-performance in-memory caching library with W-TinyLFU eviction policy32Apache-2.0
flourish-unsendConvenient and full-featured signals for Rust (thread-local variant).31MIT OR Apache-2.0
srlion-xutexan extremely fast async mutex with alternative sync API31MIT
boson-backend-natsNATS JetStream KV QueueBackend adapter for Boson Tier 331MIT
boson-backend-scyllaScyllaDB QueueBackend for Boson31MIT
boson-backend-redisRedis QueueBackend adapter for Boson (ZSET ready queue + JSON job bodies)31MIT
bask-tasksPredefined workers and routers for bask: row-count batching and chunking (use the bask crate)31MIT OR Apache-2.0
cineymaA lightweight actor framework for Rust with typed messages, OTP-style supervision, and distributed clustering31MIT
zubr_dspa modular, fully parallelizable DSP pipeline for rust31non-standard
llingr-kafkaThe llingr concurrent message processing engine for Kafka31AGPL-3.0-only OR LicenseRef-Llingr-Commercial
deref-once-lockA std::sync::OnceLock wrapper that dereferences to its initialized value.30MIT OR Apache-2.0
rakka-inference-runtime-litellmLiteLLM proxy provider for rakka-inference — implements ModelRunner against the LiteLLM unified API gateway, fronting…30Apache-2.0
takoudeLock-free SPSC ring buffer with per-slot sequence flags, tuned for low latency.30MIT
lace-nativeRust bindings for the Lace work-stealing framework for multi-core fork-join parallelism30Apache-2.0
atomictrackA place to play with monotonic atomic numbers30MIT OR Apache-2.0
rakka-persistence-awsAWS DynamoDB journal and snapshot store for rakka — single-table design with conditional writes.30Apache-2.0
qubit-fast-casLightweight u64 compare-and-swap cells and retry-aware execution30Apache-2.0
quick_cache_memleak_fixLightweight and high performance concurrent cache30MIT
walchanA persistent mpsc-like channel backed by a write-ahead log (WAL).29MIT
rakka-inference-runtime-anthropicAnthropic Messages API provider for rakka-inference — implements ModelRunner against api.anthropic.com, with cost table, error…29Apache-2.0
ordagA high-performance DAG engine with static alias proofing. Validates graph topology before execution to eliminate runtime borrow…29MIT OR Apache-2.0
oxigeo-clusterDistributed geospatial processing cluster for OxiGeo29Apache-2.0
oxigeo-gpu-advancedAdvanced GPU computing with multi-GPU support, memory pooling, and shader optimization for OxiGeo29Apache-2.0
snowdrop-id-postgresPostgres-backed machine-ID leasing for snowdrop-id generators29MIT
fermioProactive IO & runtime system29Apache-2.0/MIT
vinequeueHigh-performance async queue library with disk persistence28MIT
omnibusA lightweight, in-process publish/subscribe event bus for Rust28MIT
uf-bosonPublic Boson facade — async work engine28MIT
atomr-infer-cliatomr-infer serve CLI binary. Boots the actor system, applies project-file [[deployment]] entries, and mounts the gateway.28Apache-2.0
events-ledgerEvents Ledger keeping track of all events for photon interactions or signal mutations/processes28MIT
rakka-coordinationLease-based coordination primitives for rakka.28Apache-2.0
rakka-discoveryPluggable service-discovery interface for rakka.28Apache-2.0
rakka-persistence-query-inmemoryIn-memory read journal for rakka-persistence-query.28Apache-2.0
rakka-persistence-redisRedis journal and snapshot store for rakka — sorted-set journal, hash snapshots, transactional batches.28Apache-2.0
rakka-persistence-cassandraCassandra and ScyllaDB journal and snapshot store for rakka — partitioned tables, prepared-statement replay.28Apache-2.0
orkesterContext-aware task scheduling.27Apache-2.0
ash-timeHybrid Logical Clocks for causality tracking with approximate wall-clock ordering across distributed nodes27Apache-2.0
effect-rsA high-performance, strictly-typed, functional effect system for Rust.27MIT
heapletA small, in-process, Redis-inspired in-memory store for Rust.27MIT
donadb-xLock-free, memory-mapped storage engine for blockchain validator state. Commutative append log, N-shard atomic buffer swap,…27Apache-2.0 OR MIT
frame-meshDistributed computing and cross-instance synchronization for AI systems27MIT
rakka-inference-runtime-geminiGoogle Gemini provider for rakka-inference — implements ModelRunner against Vertex AI and AI Studio endpoints, with cost table,…27Apache-2.0
rakka-hostingBuilder API for wiring a rakka system together — config, DI, setup hooks.27Apache-2.0
event_queue_ggmaldoLock-free MPSC/SPSC event queues for DAW — UI to audio thread and back, zero allocations27MIT
agent-kernelMinimal Agent orchestration kernel for multi-agent discussion27MIT OR Apache-2.0
rakka-persistence-azureAzure Table Storage journal and snapshot store for rakka.27Apache-2.0
rakka-persistence-sqlSQL journal and snapshot store for rakka — sqlx-backed; SQLite default; Postgres / MySQL / MSSQL features.27Apache-2.0
rakka-persistence-mongodbMongoDB journal and snapshot store for rakka — indexed collections, atomic multi-document inserts, BSON payloads.27Apache-2.0
cmpthTrait-composable user-level threading (ULT) with work-first fork/join scheduling — a Rust reimplementation of ComposableThreads27Apache-2.0
dyadA lightweight asynchronous task executor with TaskGroup as core abstraction for task management.26MIT
procrefCross-platform process reference counting for shared service lifecycle management26MIT
mraA lightweight framework for building headless, programmable AI agents in Rust. Tokio-native runtime with built-in supervision,…26MIT
catalyxA reactive streaming runtime inspired by join calculus and chemical reaction models26MIT
named_queueNamed, typed, bounded work-sharing queues over flume with graceful shutdown26Apache-2.0
polyboxMessage-passing abstractions to make working with channels and actors a more seamless experience26MIT OR Apache-2.0
signal-modCross-platform OS signal handling and graceful-shutdown orchestration for Rust. One API for SIGTERM, SIGINT, SIGHUP, SIGQUIT,…25Apache-2.0
numaperf-benchBenchmark suite and CLI tools for numaperf25MIT
daedalus-engineHigh-level engine facade for planning and running Daedalus graphs.25MIT OR Apache-2.0
nostro2-ring-relayLock-free ring buffer relay pool for the Nostr protocol.25MIT
olive-treeHazelcast like distributed data grid in Rust24MIT
cron-task-schedulerA high-performance async cron scheduler for Rust, supporting both async and blocking tasks with fine-grained scheduling policies.24SSPL-1.0
pollen-rsEmbedded decentralized distributed task scheduler24MIT OR Apache-2.0
roda-stateA zero-copy, lock-free multi-threaded stage engine for ultra-low latency pipelines.24Apache-2.0
tower-scope-spawnstructured concurrency management for tower services24MIT OR Apache-2.0
kimi25-opensourceAgent swarm orchestrator inspired by Moonshot AI's Kimi K2.5 model. Lightweight toolkit for coordinating autonomous agent swarms…24MIT
si-exocortexPersistent cognitive substrate for multi-agent systems — conservation-law aware decision making, tiered memory, and inter-agent…24MIT
gsc-gcraHigh-performance GCRA (Generic Cell Rate Algorithm) rate limiting library23MIT
des-cartesDesCartes: A deterministic, replayable, discrete-event simulator for Rust23Apache-2.0
torqueBlockchain testing framework built on distributed systems principles23MIT OR Apache-2.0
dstate-kameoKameo adapter for the dstate distributed state crate23MIT
parlayA Toolkit for Programming Parallel Algorithms on Shared-Memory Multicore Machines23MIT OR Apache-2.0
stdexec-rsA Rust port of C++ stdexec (P2300) — Senders/Receivers for structured concurrency23MIT
token-budget-poolShared token + dollar budget across concurrent LLM tasks. Thread-safe, returns BudgetExceeded when a record would push past a…23MIT OR Apache-2.0
pantographWait-free channels23Apache-2.0 OR MIT
mod-signalUnified OS signal handling for Rust. SIGTERM / SIGINT / SIGHUP / SIGPIPE and Windows equivalents through one API. Graceful…23Apache-2.0
acmapAn actor-style sharded async map inspired by DashMap-like APIs.23MIT
runqMacro-based job orchestrator with distributed locking and automatic retries23MIT
timerwheelHierarchical timer wheel for delayed task scheduling with pluggable executors.23Apache-2.0
easi-jobIn-process periodic-job primitive (Schedule + JobSet) with graceful shutdown. Not a queue.23MIT
ticketingLightweight async client for a network distributed lock system: acquire and release named locks (tickets) over TCP, with…23MIT
starioa placeholder22MIT OR Apache-2.0
context_arenaZero-copy and lock-free LLM context engine22MIT
watchable-rsObservable values with change tracking and async support22MIT OR Apache-2.0
dstate-ractorRactor adapter for the dstate distributed state crate22MIT
rayon-ca-byondCrate that integrates basics for interaction with rayon-ca for BYOND projects, and can serve as example implementation of…22non-standard
scry-indexA concurrent sorted key-value map backed by learned index structures22MIT OR Apache-2.0
hflowA lightweight concurrent task progress manager for CLI applications.22MIT
VesselRsShared memory primitives for multi-agent orchestration22MIT
llm-syncCRDT and vector clock primitives for distributed LLM agent state synchronization22MIT
xyntheA unified orchestration framework for autonomous intelligence with temporal continuity22non-standard
motosan-workflow-swarmDynamic task queue execution engine for motosan-workflow22MIT
dtact-utilAsync utilities for Dtact: I/O, filesystem, process, signal, stream and timer primitives with lock-free native…22MIT or Apache-2.0
aether-dataplaneBusiness-neutral shared-memory data plane for Aether edge gateways21MIT OR Apache-2.0
kraquenA fast, thread-safe, and highly ergonomic generic queue with dual modes and bounded eviction.21MIT OR Apache-2.0
nv-metricsOptional OpenTelemetry metrics exporter for the NextVision runtime21MIT OR Apache-2.0
arena-spscA lock-free single-producer single-consumer byte channel backed by a flat arena21MIT
ruvix-smpSymmetric Multi-Processing support for RuVix Cognition Kernel (ADR-087 Phase C)21MIT OR Apache-2.0
alpha-core-frameworkHigh-performance modular Rust framework for async task orchestration and data pipelines.21MIT
rust-quepaxaRust-native QuePaxa consensus core21MIT
mpmc-queueA bounded multi-producer multi-consumer queue using Mutex + Condvar21MIT
llm-budget-windowTime-windowed token + USD budget. Define multiple rolling windows (e.g. $5/minute, $100/day) and reject when any window's cap…21MIT OR Apache-2.0
chaincodec-batchHigh-throughput batch decode engine for ChainCodec — Rayon parallel processing21MIT
carpoolDeduplicate and batch concurrent async requests through a collection window21MIT OR Apache-2.0
wasm-actor-bridgeTyped, zero-copy Web Worker bridge for Rust/WASM actor systems20MIT OR Apache-2.0
micadbEmbeding DB20MPL-2.0
biasedrcAn implementation of biased-reference counting20MIT OR Apache-2.0
goldielocksCollection of common locking/signalling patterns.200BSD
logosq-os-schedulerQuantum-classical task scheduler for LogosQ Quantum OS20MIT
groupcache-ngA distributed caching and cache-filling library with near-realtime streaming invalidation, lock-free routing, and built-in…20MIT
bzzz-cliBzzz CLI - Command line interface for Agent orchestration20MIT
wombatkv-cabiC ABI over WombatKV. Produces libwombatkv.dylib + wombatkv.h so C/C++ engines (ds4, llama.cpp, custom) integrate without a Rust…20Apache-2.0
theater-chain-formatHuman-readable text format for Theater chain events. Lossless encode/decode of `ChainEvent` to/from a line-oriented EVENT-block…20Apache-2.0
anycms-event-actixActix-web integration for anycms-event20MIT
must-mcOptimal dynamic partial-order reduction for message-passing concurrency (the Must algorithm, OOPSLA 2024)20MIT
sombrax-actorsA lightweight actor framework with broadcast and work-queue channels, shared state, and derive macros for message-driven Rust…19MIT OR Apache-2.0
pfindParallel directory walker tuned for APFS. ~5x faster than fd/rg on macOS via work-stealing and per-volume worker tuning.19MIT OR Apache-2.0
websocketingWebSocketing is a WebSockets actor framework.19MIT OR Apache-2.0
dag-executorA production-ready DAG executor with state management and advanced patterns19MIT OR Apache-2.0
rime-xdsLock-free delta-xDS control plane for Envoy. Incremental updates, zero-copy fan-out, and content-addressed versioning — the…19MIT OR Apache-2.0
cgpuA tunable GPU compute executor with automatic CPU fallback, byte-based batching, and inline shader generation.19MIT OR Apache-2.0
abyo-crdtPure Rust CRDT library: Fugue-Maximal list, OR-Set, LWW-Map, PN-Counter, Peritext rich text, Yjs Delta interop, anchor-based…19MIT OR Apache-2.0
esearchstatA high-performance desktop GUI for incredibly fast text searching, powered by ripgrep.19MIT
pureflowA flow-based programming (FBP) workflow engine for building concurrent data pipelines19MIT
escapementDeterministic time for multi-threaded synchronous code: a virtual clock that only advances when every participating thread is…19MIT OR Apache-2.0
gpuemu-daemonGPU-less validation daemon for deep-learning kernels: fp64 reference oracle, op-schema fuzzing, calibrated tolerances, and…18MIT OR Apache-2.0
soul-hubIn-process synchronous publish/subscribe event hub.18MIT
rate-limit-guardCross-session rate limit guard for LLM providers.18Apache-2.0
ct-simdSIMD-parallel batch snap on the Pythagorean manifold — Rayon + AVX2, 8x throughput18MIT
rusty-taskflowA type-safe async DAG task flow framework18MIT
santh-bufpoolTyped buffer recycling with fixed size classes and lock-free checkout/return18MIT
causal-dagLock-free append-only causal DAG (G-Set CRDT) for AI agent memory.18Apache-2.0
batchpressHardware-adaptive batch image compression to WebP with a Rayon pipeline18MIT
application-toysLightweight application primitives for async Rust — typed event bus, async trait support, and more to come18non-standard
rosiaA robotic middleware18Apache-2.0
anycms-event-redisRedis transport for anycms-event distributed event bus18MIT
morelDeterministic, low-latency stream processing with live execution and replay.18MIT OR Apache-2.0
atomr-accel-cubCUB-backed device-wide reductions, scans, sorts, histograms, and selects, surfaced as an atomr actor compiled per-(op, dtype) via…17Apache-2.0
fleet-coordinateFleet coordination via zero-holonomy consensus and Laman rigidity17MIT
magicqueueLightweight message queue with pluggable drivers (memory/Redis), persistence, priorities, retries and a dead-letter queue.17MIT
barkerA small, synchronous trait-object event bus with type-safe handlers, TTL, and priority metadata.17MIT OR Apache-2.0
ganglionReusable, domain-free cluster coordination engine (raft-backed). Name reserved; the full release is in development.17MIT
ravel-supportSupport services for Ravel: async job queue, task scheduler, file storage17MIT
aura-zonesFile and function ownership zones for multi-agent codebases. Mutex for AI agents — claim, detect collisions, coordinate.17Apache-2.0
win32-workerRAII worker thread with Win32 Event-based graceful shutdown17MIT OR Apache-2.0
warp-mapGPU-native concurrent hash map with DashMap-like ergonomics. Bucketed cuckoo hashing, SoA layout, CUDA kernels; batched…17MIT OR Apache-2.0
rok-lockDistributed lock primitives (in-memory, Redis, PostgreSQL) for the rok framework17MIT
anycms-event-axumAxum integration for anycms-event17MIT
sheafsyncMotor de consistencia sin coordinación vía cohomología de haces celulares16MIT
duotrieAn in-memory storage adapter for the upstream jmt Jellyfish Merkle Tree crate, with a lock-free concurrent variant built on…16Apache-2.0
agent-lockCooperative execution lock to prevent concurrent agent runs on the same key16MIT
reflow_pack_sdkAuthor-facing crate for building Reflow actor packs — safe wrapper over the pack ABI plus the #[reflow_pack] macro.16MIT OR Apache-2.0
reflow_rt_capiC ABI bindings for the Reflow runtime — the shared native surface consumed by Go (cgo), Kotlin/Java (JNI), and other non-Rust…16MIT OR Apache-2.0
reflow_rt_wasmBrowser-WASM distribution of the Reflow runtime — exposes Graph, Network, Actor, Message to JS via wasm-bindgen.16MIT OR Apache-2.0
aetherflowA high-performance, thread-per-core actor runtime for Rust. Messages move with zero-copy ownership, mailboxes are lock-free, and…16MIT OR Apache-2.0
apollo-blockingTower service for dispatching CPU-bound work to the tokio blocking thread pool with cooperative cancellation16Elastic-2.0
simple-throttleA small throttle utility that collects items and provides a way to handle them after a configured delay.16MIT
icl_systemBFT consensus kernel with predictive fixed-point pressure field layer16Apache-2.0
scry-gpuLightweight GPU compute — dispatch shaders without the graphics baggage16MIT OR Apache-2.0
sutegi-pubsubsutegi's publish/subscribe broker: topic fan-out over a Broker seam, zero third-party dependencies. In-process by default; the…16MIT
flowbrigadeRust bindings for FlowBrigade's C ABI.16Apache-2.0