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.
sync-engineHigh-performance tiered sync engine with L1/L2/L3 caching and Redis/SQL backends551AGPL-3.0
kanal-plusFork of kanal with extra features (drain_into_blocking, into_stream)551MIT
mod-eventsA high-performance, zero-overhead event dispatcher library for Rust550Apache-2.0
dactorAn abstract framework for distributed actors in Rust548MIT
cemcCem language compiler - A concatenative language with green threads and linear types546MIT
jacquesHigh-performance lock-free MPMC queues with horizontal scaling and zero-allocation operation546MIT OR Apache-2.0
tokio-fusionA high-performance thread pool service based on Tokio544Apache-2.0
pokeys-threadAdvanced threading architecture for multi-device PoKeys applications544LGPL-2.1
actionqueue-workflowWorkflow primitives for ActionQueue: DAG dependencies, task hierarchy, cron scheduling, and dynamic submission.544Apache-2.0
taskmillAdaptive priority work scheduler with IO-aware concurrency and SQLite persistence544MIT
taktora-ethercat-esiParser for EtherCAT ESI (slave information) XML into a faithful typed IR (identity, PDOs, sync managers, mailbox, distributed…544Apache-2.0 OR MIT
fluent-fsmA simple way to create a state machine540MIT
zeta-inferenceUnified inference runtime for high-performance LLM execution539MIT OR Apache-2.0
daedalus-coreCore types and shared utilities for the Daedalus dataflow stack.539MIT OR Apache-2.0
eruditeA fully-asynchronous, sandboxed, language-agnostic, test running library532Apache-2.0
szalWorkflow engine — step/flow execution with branching, retry, rollback, and parallel stages531AGPL-3.0-only
numaperf-shardedPer-node sharded data structures for NUMA systems530MIT OR Apache-2.0
eshanized-polarisRust-native distributed compute and orchestration framework for scaling concurrent workloads528MIT
bias-shared-arenaA thread-safe & efficient memory pool527MIT
extra_resultAdd extra methods to `Result` enum.527MIT
taktora-executor-tracingtracing-based Observer for taktora-executor.522Apache-2.0 OR MIT
noxu-repReplication and high availability for Noxu DB521Apache-2.0 OR MIT
kithara-platformCross-platform primitives (sync, time, thread) for native and wasm32.521MIT OR Apache-2.0
taktora-connector-canCAN (SocketCAN) reference connector for the taktora-connector framework. Implements BB_0070 (FEAT_0046).520Apache-2.0 OR MIT
prism3-concurrentConcurrent utilities library providing thread pools, task scheduling, synchronization primitives and other concurrent programming…517Apache-2.0
spraggaA scalable concurrent priority queue with relaxed ordering semantics514MIT
taktora-fieldbus-od-coreShared object-dictionary IR for fieldbus device descriptions (Identity, DataType, dictionary entries).514Apache-2.0 OR MIT
qubit-thread-poolDynamic and fixed thread pool executor services for Qubit Rust libraries513Apache-2.0
vex-runtimeTokio-based agent orchestration for VEX513Apache-2.0
dstructsA collection of high-performance data structures for Rust512MIT
kotoba-distributedDistributed execution engine for Kotoba graph processing system511MIT OR Apache-2.0
easerxA reactive MVI (Model-View-Intent) framework for Rust.511MIT
code-mesh-cliCommand-line interface for the Code-Mesh distributed swarm intelligence system511MIT
data-portal🌀 Data Portal - 零拷贝数据传送门 | Zero-copy high-performance data transport510MIT
hsipcHigh-performance inter-process communication framework in Rust510MIT OR Apache-2.0
t2_busAn inter- or intra-process message bus supporting publish/subscribe and request/response.509MIT
act_rs_tokioAct.rs Tokio is a minimal Tokio oriented actor framework.508MIT OR Apache-2.0
fluxion-execAsync stream subscribers and execution utilities for fluxion506Apache-2.0
rapidzIn development500MIT
blewmBlewm: A Bloom Filter that Bloo(m) my Mind494MIT
fws_actorsfastwebsockets clients and servers in actors.494MIT OR Apache-2.0
nblf-queueAtomic, lock-free MPMC queues based on the nblfq algorithm494MIT
homomorphic_actorsHomomorphic Actors is a look at homomorphic encryption as run inside an actor model system.487Apache-2.0
xactoSimple Erlang-style actors for Rust.487MIT
fraktor-utils-core-rsPortable no_std toolbox primitives for the fraktor actor runtime479MIT OR Apache-2.0
parallel-bz2-reduxCorrect, high-performance parallel bzip2 compression and decompression479CC0-1.0
lockness-executorTODO476Apache-2.0
actionqueue-budgetBudget enforcement, suspend/resume, and event subscriptions for the ActionQueue task queue engine.476Apache-2.0
lockness-atomicsTODO475Apache-2.0
memkitDeterministic, intent-driven memory allocation for systems requiring predictable performance475MPL-2.0
lockness-vecsTODO474Apache-2.0
lockness-bagsTODO474Apache-2.0
salixManage thousands of devices blazingly fast474MIT
numaperf-memNUMA-aware memory allocation and placement policies469MIT OR Apache-2.0
tower-resilience-executorExecutor delegation layer for Tower services - parallel request processing469MIT OR Apache-2.0
salix-agentManage thousands of devices blazingly fast467MIT
zmcpZMCP - Full-Stack AI Framework for Agent Coordination. Rust implementation coming Q2 2025.466MIT
scaloSelf-regulating runtime for hyperscale-grade data-plane services. Config, logging and metrics come pre-wired as singletons you…465Apache-2.0
starlang-gen-serverGenServer pattern for Starlang464MIT OR Apache-2.0
salix-controllerManage thousands of devices blazingly fast462MIT
atomrNative Rust runtime for actor-based concurrent and distributed systems. Umbrella crate — pull in subsystems via feature flags.461Apache-2.0
timeforrustA task timer library for Rust460MIT
bloomzA fast, flexible Bloom filter library for Rust with parallel operations support459MIT OR Apache-2.0
act_rs_smolAct.rs smol is a minimal smol oriented actor framework.458MIT OR Apache-2.0
reflow_actor_macroProcedural macros for declaring Reflow actors.457MIT OR Apache-2.0
reflow_graphGraph data structures for Reflow — nodes, edges, IIPs, exports, and analysis.457MIT OR Apache-2.0
rukkoA Rust library for communicating with JVM-based Pekko actors457MIT
razor-rpc-tcpThe TCP/unix transport layer of razor-rpc.
razor-rpc is a modular, pluggable RPC for high throughput scenario, supports various…457MIT
zorgZorg - Full-Stack AI Framework for Agent Coordination. Rust implementation coming Q2 2025.456MIT
numaperf-perfNUMA locality observability and metrics collection456MIT
razor-rpc-macrosThe macro crate for razor-rpc.
razor-rpc is a modular, pluggable RPC for high throughput scenario, supports various…456MIT
numaperf-ioDevice locality discovery for NICs and storage454MIT OR Apache-2.0
numaperf-schedTopology-aware work scheduling with locality-preserving stealing454MIT
ethos« τοῦ γὰρ ἤθους αἱ τοιαῦται δοκοῦσι κινήσεις εἶναι… » (NE 1128a.10)453AGPL-3.0-only
some_global_executorReference thread-per-core executor for the some_executor crate.451MIT OR Apache-2.0
beetry-messageInternal beetry crate. For the public API, check the beetry crate.449MIT
mayuriAn Asynchronous WebSocket Client Library.443MIT
async-signal-with-infoAsync signal handling442Apache-2.0 OR MIT
kithara-bufpoolSharded buffer pool for zero-allocation audio hot paths.442MIT OR Apache-2.0
doublebufConcurrent auto-swapping double buffer439MIT
taktora-ethercat-netcfgParser and in-memory IR for the EtherCAT network-config YAML (build-host codegen toolchain).437Apache-2.0 OR MIT
d-engine-corePure Raft consensus algorithm - for building custom Raft-based systems436MIT OR Apache-2.0
qubit-batchOne-shot batch execution and processing with sequential and scoped parallel utilities436Apache-2.0
hft-jobsAllocation-free job system for HFT and real-time systems431LGPL-3.0-or-later
ranged-mmapType-safe memory-mapped file library with lock-free concurrent writes to non-overlapping ranges430MIT OR Apache-2.0
hyperstreamdbHyperStreamDB - Serverless Index-Streaming Database with Overlay Indexing and Vector Search430MIT AND Apache-2.0
nexus-async-netAsync WebSocket adapter for nexus-net. Tokio-compatible, zero-copy, SIMD-accelerated.428MIT OR Apache-2.0
actionqueue-runtimeAsync dispatch loop, embedded API, and runtime configuration for the ActionQueue task queue engine.427Apache-2.0
solti-modelSolti SDK domain model.423Apache-2.0
kojin-coreCore traits, types, and worker runtime for the kojin task queue423MIT OR Apache-2.0
reflow_actorActor trait, message types, ports, state, and stream handles for the Reflow runtime.421MIT OR Apache-2.0
theater-handler-tcpRaw TCP networking handler for Theater WebAssembly runtime421Apache-2.0
yuan-idA lightweight and high-performance u64 ID generator with customizable step allocation and async persistence.417MIT
caducusBounded MPSC/SPSC channel with expiry416Apache-2.0
disrupt-rsConcurrent Ringbuffer inspired by the LMAX Disruptor.415MIT
lfrlockA Lock-Free Read Lock where reads never block and writes are serialized using Mutex414MIT OR Apache-2.0
datum-agentEmbeddable Datum job registry and lifecycle supervisor413Apache-2.0
ratelockZero-dependency, zero-allocation, lock-free token bucket rate limiter for Rust (std + no_std).411Apache-2.0
extractdbA thread-safe, in-memory hash store supporting concurrent fetches and writes.410MIT OR Apache-2.0
atomr-infer-runtime-openaiOpenAI Chat Completions provider for atomr-infer — implements ModelRunner against api.openai.com, with cost table, error…409Apache-2.0
simple_json_serverA simple way to build a JSON-based server with automatic JSON serialization/deserialization, error handling, async support, type…408non-standard
sefer-allocA safe-by-construction, 100% Rust memory toolkit (no C/C++ libraries — no libnuma/mimalloc/jemalloc/snmalloc/tcmalloc): a…405MIT OR Apache-2.0
adze-concurrency-normalize-coreSingle-responsibility helpers for normalized concurrency bounds.400MIT OR Apache-2.0
aprender-distributeSovereign AI-grade distributed computing primitives for Rust (CPU, GPU, HPC)400MIT
mechanics-coremechanics automation framework (core)399Apache-2.0 OR MPL-2.0
embedded_mutexA minimal, no_std, non-blocking mutex for embedded Rust.398MIT
taktora-ethercat-netcfg-codegenCode generator turning the taktora-ethercat-netcfg IR into Rust source (PDO maps, routing tables) for the…398Apache-2.0 OR MIT
theater-handler-supervisorSupervisor handler for Theater WebAssembly runtime - child actor management397Apache-2.0
justalock-clientA distributed lock powered by the justalock service395LGPL-3.0-only
quick-boolA lock-free boolean implementation using atomic operations392MIT
rumpsteak-aura-fsmSession types for asynchronous communication between multiple parties (Aura flavored).391MIT
concurrent-pqueueA high-performance, thread-safe priority queue with dynamic priority updates389MIT
atomr-infer-testkitTest kit for atomr-infer: MockRunner plus wiremock-based provider fixtures (MockOpenAi, MockAnthropic, MockGemini,…388Apache-2.0
bitcoinleveldb-posixtoolsPOSIX-focused LevelDB support utilities: singleton environment wiring, mmap and open-file limit management, process-local POSIX…384MIT
honkerSQLite-native task runtime: durable queues, streams, pub/sub, and scheduler. Ergonomic Rust wrapper over honker-core.383MIT OR Apache-2.0
rabia-kvstore-exampleKey-value store state machine implementation example using the Rabia SMR protocol381Apache-2.0
sackA lock-free data structure for adding & retrieving items381MIT
koda-sandboxCapability-aware sandbox layer for Koda — kernel-enforced FS/net/exec policies (refs #934)380MIT
rabia-counter-exampleSimple counter state machine implementation example using the Rabia SMR protocol380Apache-2.0
rskvHigh-performance KV store inspired by Microsoft FASTER379MIT OR Apache-2.0
yep-cocYet another circular buffer. This one happens to be a zero copy, MPMC, lock free queue.379LGPL-2.1-or-later
rabia-banking-exampleBanking ledger state machine implementation example using the Rabia SMR protocol378Apache-2.0
numaperfNUMA-first runtime for latency-critical Rust applications378MIT
nv-coreShared types, IDs, timestamps, geometry, errors, metadata, health events, and metrics for the NextVision runtime.376MIT OR Apache-2.0
fluxmapA thread-safe, transactional, and concurrent in-memory key-value store for Rust. Offers ACID guarantees with Serializable…375MIT
qubit-rayon-executorRayon-backed CPU-bound executor service for Qubit Rust libraries375Apache-2.0
hardy-asyncRuntime-agnostic async primitives for the Hardy DTN implementation374Apache-2.0
ida-rsA thread-safe, no_std, sparse ID allocator using a radix tree. Ideal for systems programming.373MIT OR Apache-2.0
atomr-agents-orgOrganizational hierarchy (Org/Department/Team) over cluster sharding.366Apache-2.0
motosan-workflow-coreCore library for the motosan-workflow DAG-based agent workflow engine364MIT
rapid_recorderHigh-performance library for tracking internal variables in concurrent Rust applications364MIT
adze-concurrency-parse-coreString parsing helpers for concurrency cap configuration values.364MIT OR Apache-2.0
rakka-remoteCross-process and cross-host actor messaging for rakka — TCP transport, framed PDU codec, ack'd delivery, endpoint state machine,…364Apache-2.0
atomr-infer-runtime-anthropicAnthropic Messages API provider for atomr-infer — implements ModelRunner against api.anthropic.com, with cost table, error…363Apache-2.0
beetry-coreInternal beetry crate. For the public API, check the beetry crate.363MIT
agentic-paymentsAutonomous multi-agent Ed25519 signature verification with Byzantine fault tolerance362MIT OR Apache-2.0
adze-concurrency-env-vars-coreCanonical concurrency environment variable names and defaults.362MIT OR Apache-2.0
dualcache-ffA wait-free, high-performance concurrent cache optimized for extreme read-to-write ratios.362MIT
atomr-infer-runtime-geminiGoogle Gemini provider for atomr-infer — implements ModelRunner against Vertex AI and AI Studio endpoints, with cost table, error…359Apache-2.0
async-io-throttlingRate-limiting Async IO358Apache-2.0
malstrom-kafkaKafka protocol sources and sinks for the Malstrom stream processing framework355MIT OR Apache-2.0
taktora-ethercat-esi-codegenCodegen layer for EtherCAT ESI device drivers: naming/collision policy, the CodegenBackend trait, and the generate entry point…355Apache-2.0 OR MIT
wpoolA thread pool that limits the number of tasks executing concurrently, without restricting how many tasks can be queued.353MIT
smc_scan_coreCore module for the Scan model checker.353Apache-2.0
qubit-tokio-executorTokio-backed executor and executor service implementations for Qubit Rust libraries352Apache-2.0
malstrom-k8sKubernetes runtime for the Malstrom stream processing framework352MIT OR Apache-2.0
antichainA coordinator-free primitive for tracking distributed progress using lattice algebra.352Apache-2.0
oxify-engineWorkflow execution engine for OxiFY - DAG orchestration, scheduling, and state management351Apache-2.0
rakka-clusterMembership, gossip, reachability, vector clocks, and split-brain resolvers for rakka clusters.351Apache-2.0
agentic-jujutsuAI-powered Jujutsu VCS wrapper for multi-agent collaboration - 10-100x faster than Git with MCP protocol support350MIT
mini_actorThe smallest, simplest Rust actor model using Tokio runtime349MIT
dynomite-engineEmbeddable Dynamo-style distributed replication engine: token-ring partitioning, gossip cluster, hinted handoff, anti-entropy,…349Apache-2.0
nodedb-bridgeLock-free SPSC ring buffer bridging Tokio (Send) and Thread-per-Core (! Send) runtimes348BUSL-1.1
incr-concurrentThread-safe incremental computation engine. Send+Sync runtime built on incr-core.343MIT
surelockDeadlock-free locks for Rust with compile time guarantees, incremental locks, and atomic lock sets.341MIT OR Apache-2.0
taktora-bounded-allocStatic pre-allocated bounded global allocator with hard caps and lock-after-init mode.341Apache-2.0 OR MIT
execution-policyClosure-first, runtime-light reliability policies (retry, timeout, circuit breaking, bounded concurrency, retry budgets) for any…340BSD-3-Clause
pericortexWorker executables and the shared ZeroMQ worker runtime for CorTeX, a processing framework for scientific documents.339CC0-1.0
treantHigh-performance, lock-free Monte Carlo Tree Search library for Rust.338MIT
nv-frameFrame abstraction for the NextVision runtime — zero-copy, ref-counted FrameEnvelope.338MIT OR Apache-2.0
theater-handler-message-serverMessage server handler for Theater WebAssembly runtime338Apache-2.0
dag-runnerA DAG runner with async support337MIT
rakka-persistenceEvent sourcing for rakka — `Eventsourced` trait, recovery permitter, async snapshotter, persistent FSM, at-least-once delivery.337Apache-2.0
raftoralFault-tolerant workflow orchestration library using embedded Raft consensus for Rust applications336MIT
main_threadCross-platform library to check if the current thread is the main thread.333Apache-2.0
kotoba-networkNetwork protocol implementation for Kotoba distributed system332MIT OR Apache-2.0
html2pdf-apiThread-safe headless browser pool for high-performance HTML to PDF conversion with native Rust web framework integration.332MIT
better-bucketA genuinely better token bucket for Rust: lock-free, allocation-free acquire path, cache-aligned, overflow-safe, with a one-line…331Apache-2.0 OR MIT
kovan-mvccMulti-Version Concurrency Control (MVCC) implementation based on the Percolator model using Kovan331Apache-2.0
adze-concurrency-env-contract-coreShared contract for concurrency environment variables and defaults.327MIT OR Apache-2.0
motosan-workflow-modelData types, traits, and graph algorithms for motosan-workflow325MIT
joerlAn Erlang-inspired actor model library for Rust325MIT
taktora-ethercat-esi-codegen-ethercrabCode-emitting CodegenBackend for EtherCAT ESI device drivers: emits the EsiDevice impl (decode_inputs/encode_outputs) targeting…325Apache-2.0 OR MIT
theater-handler-runtimeCore runtime handler for Theater WebAssembly runtime - logging, state, lifecycle325Apache-2.0
gorustGo-style concurrency in Rust - bringing Go-style concurrency patterns to Rust with familiar primitives like goroutines and…323MIT
async-observeAsync single-producer, multi-consumer channel that only retains the last sent value322Apache-2.0 OR MIT
bb-irFoundation IR types for the bytesandbrains framework — prost-generated ONNX + `bb.core` proto bindings.320AGPL-3.0-or-later
solti-runnerSolti SDK runner plugin trait.320Apache-2.0
loom-rsWeaving threads together - A bespoke thread pool runtime combining tokio and rayon with CPU pinning capabilities320MIT
rediqA distributed task queue framework for Rust based on Redis320MIT OR Apache-2.0
genswapGeneration-tracked ArcSwap wrapper for 5-1600x faster cached reads in read-heavy workloads319MIT OR Apache-2.0
beetry-editor-typesInternal beetry crate. For the public API, check the beetry crate.318MIT
taktora-cyclic-fieldbusCyclic process-data fieldbus seam (CyclicFieldbus trait) for taktora motion.318Apache-2.0 OR MIT
beetry-channelBeetry library with reusable channel implementations.315MIT
eridani-hpc-sdkSDK for building Eridani HPC distributed computing programs314MIT
taktora-ethercat-netcfg-buildbuild.rs glue turning an taktora-ethercat-netcfg network.yaml into a generated Rust module in OUT_DIR.314Apache-2.0 OR MIT
taktora-ethercat-netcfg-cliCommand-line front end for the taktora-ethercat-netcfg toolchain (expand a network.yaml to generated Rust source).313Apache-2.0 OR MIT
occams-rpc-tcpThe streaming interface of occams-rpc.
occams-rpc is a modular, plugable RPC for high throughput scenario, supports various…312MIT
datum-mqNative Kafka sources and sinks for Datum streams311Apache-2.0
velocityxA production-ready Rust crate for lock-free concurrent data structures with performance monitoring307MIT OR Apache-2.0
razor-rpcrazor-rpc is a modular, pluggable RPC for high throughput scenario, supports various runtimes,
with a low-level streaming…306MIT
fcdb-concurConcurrency primitives and async utilities for FCDB305Apache-2.0
rs_eventsA flexible and ergonomic event emission crate for Rust. Supports both std/threaded and no_std/alloc environments, with tagging,…305MIT OR Apache-2.0
bb-deriveProc-macro support for the bytesandbrains framework.304AGPL-3.0-or-later
llt-rsLow-Latency Primitives Toolkit for Rust304MIT
theater-handler-storeContent storage handler for Theater WebAssembly runtime303Apache-2.0
wcqA Scalable, Portable, and Memory-Efficient Lock-Free FIFO Queue (DISC '19)302MIT OR BSD-2-Clause
tendrilsTiny, flexible helpers for managing shared state (Arc<Mutex<T>> / Arc<RwLock<T>>) safely in async Rust.302MIT
potassiumA lean and mean job scheduler300MIT
copy-channelsA collection of cross-thread channels for copyable types297MIT