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.
tomii-typesType-erased value types (CmTypes) shared across Tomii plugins and runtime73Apache-2.0
ax-cacheHardware-aware concurrent cache engine.73MIT
maybe-once-macrosA singleton. Maybe.72MIT
nv-runtimePipeline orchestration, feed lifecycle, output, provenance, and concurrency for the NextVision runtime.72MIT OR Apache-2.0
nv-test-utilTest harnesses, synthetic frames, mock stages, and controllable clock for NextVision.72MIT OR Apache-2.0
fraktor-rsSpecification-driven actor runtime bridging Akka/Pekko and Proto.Actor semantics across no_std and std targets.72MIT OR Apache-2.0
seqpackerHigh-performance sequence packing for LLM training72MIT
subethaSubEtha (CXC, Cross-Context Channel): MMF-backed cross-process IPC plus adaptive in-process primitives - one byte layout for…72MIT
imece_coreIMECE v0.2.0 - Local-First Autonomous Agent Framework. Zero API dependency. Zero cloud lock-in. Full sovereignty.72AGPL-3.0-only
forkunionLow-latency NUMA-aware fork-join thread-pool with zero allocations, syscalls, CAS, or false-sharing on the hot path72Apache-2.0
sleep-utilsSmart sleep utilities with flexible input formats and automatic zero-value handling71MIT OR Apache-2.0
reflow_rtThe public Rust runtime crate for building and running Reflow graph workflows.71MIT OR Apache-2.0
anycms-event-deriveProcedural macros for anycms-event71MIT
jsmpiA browser-oriented MPI compatibility layer for Rust/WASM using Web Workers70MIT
aeron-glideSafe, idiomatic Rust wrapper for the Aeron C++ API via cxx70AGPL-3.0-or-later
tianshu-llm-openaiOpenAI-compatible LlmProvider adapter for workflow-engine69Apache-2.0
groupcache-ng-pbProtocol buffer definitions for groupcache-ng (internal crate)69MIT
rakka-accelBackend-agnostic compute-acceleration core. Defines the AccelBackend trait, AccelRef<T> typed pointers, AccelError enum, and…68Apache-2.0
Actorizerust actor framework66MIT OR Apache-2.0
rate-netA powerful, lock-free rate limiter for Rust: multiple algorithms behind one trait, sharded per-key state, bounded-memory…66Apache-2.0 OR MIT
wpj-tg-rcore-tutorial-sync-mpMulticore-ready synchronization primitives for rCore tutorial OS.66GPL-3.0
scattoscatto - low-latency messaging primitives66MIT
esox_objectpoolHigh-performance, thread-safe object pool with async support, circuit breaker, eviction, health monitoring and Prometheus metrics66MIT
agentorAgent-native Actor runtime — an Actor-model execution platform designed for AI Agents66MIT
bzzz-coreBzzz core library - Declarative orchestration engine for AI Agents66MIT
rayrustRust SDK for Ray distributed computing — wraps the Ray C++ SDK via FFI66Apache-2.0
wombatkv-nodeHigh-level WombatKV node API, store + lookup + touch + foyer-backed local cache. The Rust surface that wombatkv-cabi wraps for…66Apache-2.0
turbo-mpmcA blazingly fast lock-free MPMC queue that beats crossbeam-channel on SPSC workloads.64MIT OR Apache-2.0
Actix-rsrust actor framework64MIT OR Apache-2.0
Acxusrust actor framework64MIT OR Apache-2.0
piyingFault-tolerant Async Actors Built on Tokio64MIT OR Apache-2.0
baskBuild Tasks: an async task-queue pipeline engine with pluggable IO, columnar formats, and predefined tasks64MIT OR Apache-2.0
goA runtime-agnostic Go-style concurrency library for Rust64MIT OR Apache-2.0
cronschedulerA high-performance async cron scheduler for Rust, supporting both async and blocking tasks with fine-grained scheduling policies.64SSPL-1.0
rakka-inference-runtime-openaiOpenAI Chat Completions provider for rakka-inference — implements ModelRunner against api.openai.com, with cost table, error…64Apache-2.0
lockbellAn RwLock that rings back when contention clears.64MIT OR Apache-2.0
anycms-eventA type-safe, async event bus system for AnyCMS64MIT
local_buflocal_buf 是一个支持多线程异步的线程缓冲区63MIT
nexir-mvcc-coreStandalone, deterministic Multi-Version Concurrency Control (MVCC) library for building durable databases63MIT OR Apache-2.0
lowletLow-latency IPC library using shared memory and lock-free structures62MIT
rakka-diDependency-injection container for rakka.62Apache-2.0
haz-execAsync task execution engine for haz.62AGPL-3.0-or-later
Actor-rsrust actor framework61MIT OR Apache-2.0
dactor-kameoKameo adapter for the dactor distributed actor framework61MIT
samara-signalsA high-performance signal library for Rust61MIT
bluetape-rs-asyncTokio-first async task helpers for bluetape-rs.61MIT
audio-melMélodium audio processing library61EUPL-1.2
legendreBlock-structured, deterministic, scheduler-driven PDE simulation framework61MIT OR Apache-2.0
cliffy-protocolsDistributed consensus protocols using geometric algebra60MIT
atomr-accel-trainDistributed training blueprints on atomr-accel-cuda: DataParallelTrainer, PipelineParallelTrainer, TensorParallelTrainer,…60Apache-2.0
bounded-taskpoolBounded taskpool with backpressure60non-standard
dactor-coerceCoerce adapter for the dactor distributed actor framework60MIT
sandlA framework for building parallel execution engines with dependency management, type-safe method dispatch, and event observation.59MIT OR Apache-2.0
legendStrict, composable saga VM for sequential workflows with compensation59MIT
housekeepingA concurrent memory reclaimer for periodic cleanups.59MIT OR Apache-2.0
dtact-ioI/O utilities for Dtact: A non-preemptive, stackful coroutine runtime featuring a lock-free context arena, P2P mesh scheduling,…59MIT or Apache-2.0
subms-rate-limitersubmillisecond.com cookbook recipe - concurrency: subms-rate-limiter. Lock-free GCRA-style rate limiter with a single-atomic…59MIT OR Apache-2.0
rawb-ioRead-ahead / write-behind byte IO: threaded Reader/Writer that decouples a pipeline stage from the kernel pipe via a background…59MIT
atomr-accel-cuda-realtimeInteractive-rate GPU actor blueprints on atomr-accel-cuda: ImageFilterPipeline, ParticleSystemActor, SpatialIndexActor,…58Apache-2.0
boson-telemetryBoson OpsLog telemetry port58MIT
carbonmapLock-free concurrent hash map for Rust with zero GC58MIT
massivelyMulti-platform GPU parallel algorithms for Rust.58MIT
taskgraph-rsNASA-grade, zero-dependency DAG task orchestrator for Rust58MIT
ph-eventingStack-allocated ring buffers for no-std embedded targets58MIT
yot_runA work-stealing, multi-threaded async executor with non-blocking scheduling.58MIT OR Apache-2.0
lienScoped lending of borrowed references58CC0-1.0
robopotatoLightweight inter-agent trust and shared state server for AI agent swarms58MIT
atomr-profilerCross-runtime actor profiler for atomr — same scenarios in Rust and Python with a shared JSON schema.58Apache-2.0
mapxHigh performance memory map with disk synchronization58MIT
wae-queueWAE Queue - 消息队列抽象层,支持内存队列、Redis 和 RabbitMQ57MIT
tomii-coreLow-latency streaming task-graph runtime for MIMO consumer-producer pipelines57Apache-2.0
tensor-wasm-tenantMulti-tenant CUDA context management (MPS-backed or per-context fallback).57Apache-2.0
crdt-traitA toolkit of composable, well-tested CRDT traits and implementations (GCounter, GSet, VectorClock, Interval Tree Clocks) with…57MIT OR Apache-2.0
rust-tangoA lock-free, high-performance IPC channel inspired by Firedancer's Tango57MIT OR Apache-2.0
batchyTransparently batch concurrent requests into efficient bulk operations57MIT
worklane-cliOperator CLI for inspecting and maintaining worklane brokers57MIT OR Apache-2.0
syncopateA hierarchical, power-aware task scheduler for Rust applications requiring precise timing control56MIT OR Apache-2.0
mariusMarius: a data-oriented reactive projection engine. PostgreSQL → AOT HTML, zero intermediate transformation.56MIT OR Apache-2.0
helixrouterAdaptive async compute routing engine: per-job strategy selection (inline/spawn/pool/batch/drop) driven by live pressure, EMA…56MIT
solti-observeSolti SDK structured logging, timezone sync, and task-lifecycle subscriber.55Apache-2.0
stagecraftAn actor framework for tokio55Apache-2.0
orbit-rsFleet-aware shared-memory rings over POSIX shared memory.55MIT OR Apache-2.0
atomr-remote-serialSerial / USB-attached transport for atomr-remoting. Wraps tokio-serial and reuses atomr-remote's framed PDU codec to ship actor…55Apache-2.0
subms-mpsc-queuesubmillisecond.com cookbook recipe - concurrency: subms-mpsc-queue. Vyukov-style multi-producer single-consumer linked queue with…55MIT OR Apache-2.0
Raf-rsRust Actor Framework, Where Every Logic Becomes an Actor.54MIT OR Apache-2.0
wsio-adapterAdapter extension point for ws.io broadcast and multi-node integrations.54MIT
atomr-serialization-hyperionSerde / bincode serializer shim for atomr, kept for layout symmetry.54Apache-2.0
worklane-metricsOptional metrics-facade observer for worklane workers and queue depth.54MIT OR Apache-2.0
mocra-dagGeneric distributed DAG execution engine for the mocra crawler framework (zero crawler coupling).54MIT OR Apache-2.0
armillaryA host-neutral actor-kernel runtime: a !Send host-kernel boundary, a Send actor harness (thread-per-actor or pooled), generation…54MIT OR Apache-2.0
hylicComposable tree computation: monoidal catamorphisms with parallel execution.53MIT
sbcMulti-producer, multi-consumer synchronous broadcast channel53MIT OR Apache-2.0
cerulion_coreCore runtime for Cerulion: zero-copy transport, wire format, codegen, scheduler, and graph execution53AGPL-3.0-only
shmringFixed-capacity, single-producer/single-consumer byte ring buffer over shared memory (same wire format as the Go and JS…52MIT
zimqTokio-based asynchronous in-process message queue.52MIT
bask-coreCore task-queue pipeline engine for bask (use the bask crate)52MIT OR Apache-2.0
limit3rResilience patterns: rate limiter, circuit breaker, bulkhead, retry52MIT
walkkitParallel filesystem walker with ignore-aware traversal and bounded work queues52MIT OR Apache-2.0
child_lockSynchronize access to many locks using only a single parent lock52MIT OR Apache-2.0
qubit-taskTask-oriented services built on top of qubit-executor and qubit-thread-pool51Apache-2.0
atrilockscollection of light weight async synchronization primitives based on atomics51MIT
loopqAn efficient SPSC lock-free ring buffer with support for no_std, Embassy, and Tokio.51MIT OR Apache-2.0
onnx-genai-schedulerContinuous batching and preemption scheduler for LLM inference51MIT
solti-prometheusSolti SDK Prometheus metrics.51Apache-2.0
worklane-schedulerOptional recurring cron scheduler that enqueues worklane jobs.51MIT OR Apache-2.0
worklane-pubsubOptional topic-to-lane fan-out layer built on the worklane facade.51MIT OR Apache-2.0
worklane-otelOptional OpenTelemetry trace-context propagation for worklane jobs.51MIT OR Apache-2.0
concurrent-sharded-stackA lock-free concurrent stack that shards a Treiber stack per thread and reclaims memory with epoch-based GC.51MIT OR Apache-2.0
low-latency-data-structuresExperimental lock-free SPSC, SPMC broadcast, and SeqLock primitives tuned for ultra-low-latency systems51MIT
saturn-ring-bufferA high-performance ring buffer50GPL-3.0-or-later
txmapA concurrent transactional hash map for Rust with fine-grained locking, internal mutability and composable transactions50MIT
futures-dagA dynamic DAG scheduler for async futures.
Provides a Stream-based API that executes futures only after all
their dependencies…49MIT
adele-ringExact multi-base arithmetic engine via the Residue Number System (RNS), with a number tower from integers to symbolic expressions…49MIT OR Apache-2.0
solti-execSolti SDK jobs execution crate.49Apache-2.0
topofoldIncremental fold propagation over a DAG with tested guarantees49MIT OR Apache-2.0
runiteAn event-loop-per-thread async runtime built on io_uring (Linux), kqueue (macOS), and IOCP (Windows)48MIT OR Apache-2.0
boson-runtimeBoson worker engine, builder, and enqueue orchestration48MIT
taskflowrsA Rust implementation of TaskFlow — task-parallel programming with heterogeneous GPU support48MIT
motosan-agent-orgEmbeddable control plane for organizations of AI agents — companies, agents, issues, budgets, approval gates, schedules,…48MIT OR Apache-2.0
greyhound-busBroadcast bus for Rust: fire-and-forget, partitioned, replay-from-cursor, and acknowledged delivery in one crate.48MIT
banuidFast, secure, 64-bit lexicographically sortable unique identifiers47MIT
boson-macrosProc macros for Boson work engine (#[boson::task])47MIT
instancyAn async reimplementation of timely-dataflow built on Tokio47MIT
ambitious-macrosProcedural macros for ambitious47MIT OR Apache-2.0
MagicStateMachinesErgonomic typestate wrappers for compiler-enforced state machines with separable contracts47MIT OR Apache-2.0
ambitiousErlang-style concurrency for Rust47MIT OR Apache-2.0
bouncingA flexible async debouncer for Rust with cancellation support, max wait limits, and event hooks47MIT
dbos-coreA Rust port of DBOS Transact: durable workflow orchestration on Postgres or SQLite46MIT
tensorwarpHigh-throughput concurrency framework optimized for data locality in massively parallel systems.46non-standard
coalesce-workerCoalescing worker thread with generation-counter stale-result rejection — the discipline needed to run tree-sitter (or any…46MIT
ubl-officeExecution environment for LogLine Agents: lifecycle, memory, and I/O coordination.46MIT
atumLock-free bidirectional Atom Table, optimized for multi-threaded workloads46MIT OR Apache-2.0
neocacheA concurrent HashMap with S3-FIFO cache eviction, forked from DashMap46MIT
boson-backend-sql-commonShared SQL QueueBackend for SQLite and PostgreSQL45MIT
global_cellA thread-safe, async-friendly, performant global cell alternative built on Rust and Tokio primitives45MIT OR Apache-2.0
mpi-rsA pure-Rust implementation of the Message Passing Interface (MPI), API-compatible with rsmpi. No C library required.45MIT OR Apache-2.0
anchormapLock-free concurrent hash map: elements never move after insertion, enabling lock-free reads45MIT
once-arcInitialize-once Arc<T> containers with zero-cost reads45MIT
imgflowHardware-adaptive batch image transcoding (WebP, JPEG, PNG, AVIF, GIF) with a Rayon pipeline45MIT
rakka-accel-cuda-realtimeInteractive-rate GPU actor blueprints on rakka-accel-cuda: ImageFilterPipeline, ParticleSystemActor, SpatialIndexActor,…44Apache-2.0
bpm-engineLightweight embeddable BPM runtime for long-running, stateful workflows with tokens, timers, Saga compensation, and crash recovery44MIT
wombatkv-daemonWombatKV daemon binary + SHM/TCP/HTTP listeners for the daemon deployment mode. Sits between multiple engine clients (ds4, future…44Apache-2.0
dagComposable dataflow and pipeline abstraction for Rust using a Directed Acyclic Graph model.43MIT OR Apache-2.0
foofightersA lightweight, work-stealing thread pool.43MIT
tower-shotA high-performance, atomic-backed rate limiting middleware for `tower`43MIT OR Apache-2.0
maniacMassively scalable Rust async runtime43MIT OR Apache-2.0
dlink-wmDynamic Linking WebAssembly Manager - A Rust-based WASM dynamic calling host43MIT
ataskAn async task implementation43MIT OR Apache-2.0
quetzal-uringLock-free multi-producer io_uring submission and multi-consumer completion, built on quetzalcoatl protocols and ququmatz syscalls43MIT
record-melMélodium recording processing library43EUPL-1.2
debounce-promisedebounce an async/promise-returning function with optional argument accumulation43MIT
pulsessA robust and flexible background job processing library for Rust.42MIT
ipc-ring48A bounded 48-byte POSIX shared-memory SPSC queue for Rust.42non-standard
listener-holderA thread-safe single-listener holder with lock-free reads for Rust42MIT OR Apache-2.0
picopubA sync/async pub-sub library with bounded queues and backpressure using Mutex and Condvar42MIT OR Apache-2.0
gridsystemA high-performance, parallel-capable 2D grid library.42MIT
labtui-asyncgitallow using git2 in a asynchronous context42MIT
secra-memoryA unified memory cache management library for plugin systems, built on top of moka42MIT OR Apache-2.0
speedemonA modern, thread-safe rate limiting library for Rust featuring four industry-standard algorithms with composable multi-limiter…42MIT OR Apache-2.0
raf-schdThrottle a function to at most one call per animation frame, with the latest arguments.42MIT
graph-clonable-refA fast, thread-safe cloneable reference that preserves reference structure during deep cloning41MIT
optx-stmHybrid Software Transactional Memory (STM) library exploring NOrec vs TL2 tradeoffs41MIT
mutfluxTyped, runtime-updatable configuration parameters with lock-free reads41MIT OR Apache-2.0
lustre-executorA blazingly fast, minimal async executor with pluggable ID generation and I/O support.41MIT
grate-limiterAnticipatory rate-limit orchestration engine for multi-provider systems. Predict limits before providers enforce them.41Apache-2.0
ml-melMélodium machine learning library41EUPL-1.2
surt-abiStable shared-memory ABI definitions for the seL4 user-space ring transport (SURT).41MIT OR Apache-2.0
rakka-accel-agentsAgentic / LLM GPU actor blueprints on rakka-accel-cuda: RagPipeline, EmbeddingCache, CpuVectorIndex, SharedGpuStateCoordinator,…40Apache-2.0
tensor-wasm-jitJIT pipeline: Cranelift detector, IR normalisation, PTX codegen, kernel cache, deopt.40Apache-2.0
surt-sel4seL4 binding for SURT: notification-backed wakeup + blocking / polling / adaptive drain loops over the platform-agnostic ring…40MIT OR Apache-2.0
intrusivelockIntrusive locks for Rust — locks that live inside the memory region they protect40Apache-2.0
fraktor-actor-std-rsfraktor std helpers for host runtimes40MIT OR Apache-2.0
takelnTyped Rust runtime for durable DAG-based agent workflows40Apache-2.0
bloomcraftProduction-grade Bloom filter library for Rust with concurrent variants and optimal performance40MIT OR Apache-2.0
timingwheelA timing wheel based timer39Apache-2.0
rust-pipeLightweight typed task dispatch from Rust to polyglot workers (TypeScript, Python, Go, Java, C#, Ruby, Elixir, Swift, PHP)39MIT OR Apache-2.0
interweaveStateless model checker for concurrent programs, powered by Optimal DPOR.39MIT
rakka-accel-trainDistributed training blueprints on rakka-accel-cuda: DataParallelTrainer, PipelineParallelTrainer, TensorParallelTrainer,…39Apache-2.0
fastskipLock-free arena-backed skip list memtable for LSM-tree storage engines39MIT
scoped-refReferences with safe runtime-checked lifetimes.39MIT OR Apache-2.0
omega-cacheA high-performance, concurrent cache for Rust with lock-free slot management and pluggable eviction policies.39MIT
subms-timer-wheelsubmillisecond.com cookbook recipe - concurrency: subms-timer-wheel. Single-level hashed timer wheel with O(1) schedule and…39MIT OR Apache-2.0
emq-sysRaw FFI bindings to EmbeddedMQ (bundles C sources by default)39Apache-2.0
tokio-interval-setRun a closure repeatedly on a fixed time interval using tokio39MIT
boson-axumHTTP admin API for Boson under /api/boson38MIT
boson-backend-memIn-memory QueueBackend adapter for tests, CI, and testkit38MIT
traceforgeTraceForge is a model checker for concurrent and distributed programs written in Rust38Apache-2.0
rotastellar-distributedDistributed compute coordination for Earth-space AI workloads38MIT
morbA lightweight in-process publish/subscribe library for Rust38MIT
megafineA multithreaded command-line benchmarking tool38GPL-3.0-or-later
pulsesA robust, high-performance background job processing library for Rust.38MIT
smc_scan_pmtlpMTL oracle for the Scan model checker.38Apache-2.0
subms-spsc-ring-buffersubmillisecond.com cookbook recipe - concurrency: subms-spsc-ring-buffer. Wait-free SPSC ring buffer with cache-line padded…38MIT OR Apache-2.0
throttle-debounceThrottle and debounce callbacks for high-frequency events like scroll, resize, and input38MIT
anycms-event-sseServer-Sent Events bridge for anycms-event38MIT
leopard_vecA high-performance parallelized vector container with deferred execution for bulk parallel operations37Apache-2.0
chump-coordNATS-backed atomic coordination layer for multi-agent Chump sessions. Phase 1: KV claim store + JetStream event bus alongside the…37AGPL-3.0-only
membarrier2Process-wide memory barrier for Linux, Windows, OSX, FreeBSD, Android, iOS and more.37MIT OR Apache-2.0
procfarmA simple binary for fire-and-forget asynchronous process execution36AGPL-3.0-or-later
sombrax-actors-macrosDerive macros (Accessor, Consumer, Producer, MultiConsumer) for the sombrax-actors framework.36MIT OR Apache-2.0