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.
taktora-connector-j1939J1939 reference connector for the taktora-connector framework. Implements BB_0098 (FEAT_0098).149Apache-2.0 OR MIT
enso-channelBatch-first, bounded, lock-free ring-buffer channels (MPSC/Fan-out) for bursty, latency-sensitive systems148MIT OR Apache-2.0
registry-ioHigh-performance event/callback registry for Rust. Sync-first with optional async. Lock-free reads, zero-allocation hot path,…148Apache-2.0 OR MIT
taktora-connector-ui-clientRust reference consumer (UI client) for the taktora MVVM UI connector: manifest discovery, contract-hash validation with…148Apache-2.0 OR MIT
tokio-eventsA modern, type-safe async event bus for Rust applications148MIT OR Apache-2.0
summer-jaebsummer-rs plugin for the jaeb snapshot-driven event bus147MIT
rakka-inference-remote-coreRemote-provider infrastructure for rakka-inference — distributed rate limiter (CRDT), circuit breaker, retry/backoff, SSE parser,…147Apache-2.0
oxigdal-clusterDistributed geospatial processing cluster for OxiGDAL147Apache-2.0
txn-dbMVCC transaction engine for Rust storage layers. Snapshot isolation and serializable transactions with multi-version concurrency…147Apache-2.0 OR MIT
rakka-inference-runtimeRuntime-agnostic actor topology for rakka-inference — gateway, request actor, dp-coordinator, engine-core, two-tier worker,…146Apache-2.0
tasker-orchestrationOrchestration system for tasker workflow coordination145MIT
ptabLock-free concurrent table optimized for read-heavy workloads145MIT OR Apache-2.0
prism3-atomicUser-friendly atomic operations wrapper providing JDK-like atomic API143Apache-2.0
fluxion-mergeMerge multiple Fluxion streams with ordering guarantees143Apache-2.0
oxscapeOxscape enables parallel flow graph (D8, Dinf) traversal in Digital Elevation Models143MIT OR Apache-2.0
kiomqAn all-in-one task-queue and orchestration library for Rust143MIT
honker-extensionSQLite loadable extension for Honker. Adds honker_* SQL functions (queues, streams, scheduler, pub/sub) to any SQLite client.142MIT OR Apache-2.0
atomr-hostingBuilder API for wiring a atomr system together — config, DI, setup hooks.142Apache-2.0
prism3-rust-atomicUser-friendly atomic operations wrapper providing JDK-like atomic API141Apache-2.0
lane_coreCore OTP actor primitives for lane_switchboards: actors, supervision, linking, monitoring, and hot upgrade139MIT
theater-handler-terminalTerminal I/O handler for Theater WebAssembly runtime139Apache-2.0
chasquimqThe fastest open-source message broker for Redis. Rust-native engine on Redis Streams + MessagePack, with Node.js and Python…137MIT
isoprenoid-unsendisoprenoid-unsend is the signals runtime framework backing flourish-unsend.136MIT OR Apache-2.0
shot-limitmultiple strategy rate limiting library136MIT OR Apache-2.0
atomr-persistence-query-inmemoryIn-memory read journal for atomr-persistence-query.136Apache-2.0
atomr-infer-runtime-ortONNX Runtime backend for atomr-infer (Whisper, embeddings, rerankers, ONNX-exported text-gen) via the ort crate. Feature-gated.134Apache-2.0
oxigdal-gpu-advancedAdvanced GPU computing with multi-GPU support, memory pooling, and shader optimization for OxiGDAL134Apache-2.0
once-arrayAppend-only single-writer fixed-capacity vector that can be shared across threads and accessed as a slice134MIT OR Apache-2.0
branch_allocatorA lock-free buddy allocator for `no_std`.134MIT OR Apache-2.0
taktora-idl-codegen-canCAN/DBC MessageBackend: emits taktora-idl-wire WireType implementations that bit-pack each field per the DBC signal layout.134Apache-2.0 OR MIT
oxigdal-haHigh availability, disaster recovery, and automatic failover for OxiGDAL133Apache-2.0
oxigdal-distributedDistributed processing capabilities for OxiGDAL using Apache Arrow Flight133Apache-2.0
celersCelery-compatible distributed task queue for Rust (Facade crate)133Apache-2.0
pooledA lightweight thread pool library with specialized pool types133MIT
taktora-idl-dbcDBC (CAN database) frontend: parses .dbc into a typed model and lowers it onto the taktora-idl-core message IR plus a CAN…133Apache-2.0 OR MIT
beetry-execInternal beetry crate. For the public API, check the beetry crate.132MIT
atomr-infer-runtime-vllmvLLM runner for atomr-infer. Hosts local LLMs via PyO3-bound AsyncLLMEngine + token-streaming. Includes Gemma 4 auto-provisioning…132Apache-2.0
atomr-infer-runtime-tensorrtTensorRT runner for atomr-infer. Wraps atomr-accel-tensorrt's TrtRuntime / ExecutionContext / ExecutionBindings behind the…132Apache-2.0
hringasno libc, no_std, pure rust bindings to io_uring132MIT
taktora-idl-wireSerde-free, no_std, no-heap runtime support for generated message (de)serializers: the WireType trait and CAN signal bit-packing…132Apache-2.0 OR MIT
axiom-spinlockA lightweight, no_std-compatible spinlock and exponential backoff implementation for low-level concurrent systems.131MIT
summer-streamIntegrate sea-streamer with summer-rs131MIT
atlas-ctxAn asynchronous task context management library130MIT
pondrsA pipeline execution library130Apache-2.0
beetry-nodeBeetry library with reusable behavior tree nodes.129MIT
fluxion-runtimeRuntime abstraction for async Rust streams129Apache-2.0
oneringbufA lock-free single-producer, single-consumer (SPSC) ring buffer with in-place mutability, asynchronous support, and virtual…129MIT OR Apache-2.0
fso-graph-builderA building block for high-performant graph algorithms. Community-maintained fork of graph_builder.129MIT
pacta-executorPacta-native execution abstractions.128MIT OR Apache-2.0
simple-queueA simple persistent queue implementation in Rust backed by PostgreSQL and tokio128MIT
cmdkitDeterministic command execution runtime for structured command graphs with configurable execution topology.127Apache-2.0
jiaxin2006-tg-rcore-tutorial-sync-t1l5Synchronization primitives for rCore tutorial OS, including mutex, semaphore, and condvar.126GPL-3.0
kojin-postgresPostgreSQL result backend for the kojin task queue126MIT OR Apache-2.0
beetry-editor-backendInternal beetry crate. For the public API, check the beetry crate.126MIT
qrush-engineLightweight Job Queue and Task Scheduler for Rust (Actix + Redis + Cron)125MIT
archxHigh-performance CPU/GPU adaptive optimization library with SIMD and Multithreading125MIT
async-sevenzAn async 7z decompressor/compressor written in pure Rust125Apache-2.0
memlink-shmHigh-performance shared memory IPC library with multi-priority messaging and lock-free ring buffers124Apache-2.0
cagelockA thread-safe static mutable wrapper123MIT
worklaneFacade API for typed background jobs in Rust services.122MIT OR Apache-2.0
wae-distributedWAE Distributed - 分布式服务支持,分布式锁、分布式ID121MIT
wae-eventWAE Event - 事件驱动模块,支持发布订阅模式121MIT
avila-parallelZero-dependency parallel library with work stealing, SIMD, lock-free operations, adaptive execution, and memory-efficient…121MIT
adze-concurrency-caps-contract-coreContract-focused API surface for concurrency caps compatibility.121MIT OR Apache-2.0
ultraslayerUltra‑low latency DRAM refresh‑stall prevention using hardware‑level hedging.121Apache-2.0
qubit-idID generation utilities for Rust, including Qubit Snowflake, classic Snowflake, Sonyflake-style, and fast UUID-like generators121Apache-2.0
worklane-sqliteSQLite-backed durable worklane broker for embedded and small services.121MIT OR Apache-2.0
wae-resilienceWAE Resilience - 弹性模式,熔断器、限流器、重试、超时120MIT
nv-mediaGStreamer backend for the NextVision runtime — source management, decode, and zero-copy bridge.120MIT OR Apache-2.0
persway-tokioSway layout and focus helper daemon that adds spiral and stack-main autotiling plus opacity and window renaming.120MIT
nv-temporalTemporal state management — trajectories, motion features, continuity, and retention for the NextVision runtime.119MIT OR Apache-2.0
atomr-persistence-mongodbMongoDB journal and snapshot store for atomr — indexed collections, atomic multi-document inserts, BSON payloads.119Apache-2.0
theater-handler-assemblerActor assembler handler for Theater WebAssembly runtime119Apache-2.0
lease-rsZero-cost ownership leasing for rust. Temporarily transfer full ownership across .await, threads, scopes, and closures with…118MIT OR Apache-2.0
compio_dispatchGlobal task dispatcher for compio applications. / Compio 应用全局任务分发器。118MulanPSL-2.0
enough-tokioTokio integration for the enough cooperative cancellation trait118MIT OR Apache-2.0
post-cortex-memoryConversation memory orchestrator for post-cortex. Ties storage + embeddings + graph + session + summary into a single lock-free…118MIT
worklane-postgresPostgreSQL-backed durable worklane broker for production services.118MIT OR Apache-2.0
selectablesLock-free channels with a unified select! macro for recv and send arms117MIT OR Apache-2.0
writecellShareable string writers using internal mutability117Apache-2.0
axicor-computeAxicor SNN engine — dual-backend (CUDA / AMD HIP) GPU compute kernels with CPU fallback117MIT OR Apache-2.0
olympipe-rsParallel pipeline library for Rust, inspired by olympipe116MIT
rakka-cluster-metricsAdaptive load balancing using cluster-wide metrics for rakka.116Apache-2.0
fso-graphA library of high-performant graph algorithms. Community-maintained fork of graph.116MIT
worklane-redisSingle-node Redis-backed durable worklane broker for production services.116MIT OR Apache-2.0
donadbDonaDB is TruthLinked Labs' lightweight, crash-safe LSM storage engine for high-throughput post-quantum blockchain nodes.115Apache-2.0 OR MIT
fastioFast cross-platform file I/O backends for Rust114Apache-2.0
chenzt23-tg-rcore-tutorial-syncSynchronization primitives for rCore tutorial OS, including mutex, semaphore, and condvar.114GPL-3.0
jiaxin2006-tg-rcore-tutorial-t2l5Student AI4OSE lab crate for Experiment 5 of rCore Tutorial: synchronization primitives (SpinLock, MutexBlocking, Semaphore,…113GPL-3.0
bytesandbrainsComposable building blocks for decentralized + federated machine learning.112AGPL-3.0-or-later
rakka-cluster-shardingSharded entities for rakka — allocation strategies, rebalance, three-phase handoff, remember-entities.112Apache-2.0
wpj-tg-rcore-tutorial-syncSynchronization primitives for rCore tutorial OS, including mutex, semaphore, and condvar.111GPL-3.0
rakka-streamsTyped reactive streams DSL for rakka — Source / Flow / Sink, junctions, framing, kill switches, hubs, stream refs.111Apache-2.0
worklane-testConformance test suite for third-party worklane broker implementors.111MIT OR Apache-2.0
segoviaA fast, chunked, memory-bounded Rust engine for electrophysiology (Neuropixels) signal processing, with Python bindings.111AGPL-3.0-or-later
chump-agent-leasePath-level optimistic leases for multi-agent coordination on a shared repo. Drop-in for any Rust-hosted agent system that needs…110Apache-2.0
pacta-driverMechanical runtime loop for Pacta execution.110MIT OR Apache-2.0
atomr-persistence-redisRedis journal and snapshot store for atomr — sorted-set journal, hash snapshots, transactional batches.110Apache-2.0
fluxion-stream-timeTime-based operators extending fluxion-stream with monotonic timestamps109Apache-2.0
atomr-persistence-awsAWS DynamoDB journal and snapshot store for atomr — single-table design with conditional writes.109Apache-2.0
subetha-coreSubstrate for the CXC / SubEtha IPC stack: handshake header, observation ring, migration generation, marshal trait, CPU-feature…108MIT
wombatkv-formatWire-format codecs for WombatKV: 16-byte universal envelope (magic + version + CRC32C + len per RFC 0018), blake3 chain hashing,…108Apache-2.0
memory-admissionMemory-aware admission gate for parallel work pipelines (sync + async APIs)107MIT OR Apache-2.0
chump-mcp-lifecyclePersistent per-session MCP (Model Context Protocol) server lifecycle: spawn child processes on session open, route JSON-RPC calls…106Apache-2.0
rakka-testkitTest scaffolding for rakka actors — TestProbe matchers, TestKit, virtual-time scheduler, multi-node spec, EventFilter.106Apache-2.0
hexga_guardUnified trait interface for Mutex, RwLock, RefCell, and other guard-based / interior mutability types105MIT OR Apache-2.0
atomr-persistence-cassandraCassandra and ScyllaDB journal and snapshot store for atomr — partitioned tables, prepared-statement replay.105Apache-2.0
atomr-persistence-azureAzure Table Storage journal and snapshot store for atomr.105Apache-2.0
freertos-in-rustPure-Rust no_std FreeRTOS kernel translation with safe Rust APIs104MIT
kojin-amqpRabbitMQ (AMQP) broker for the kojin task queue104MIT OR Apache-2.0
kojin-dashboardJSON API dashboard for monitoring the kojin task queue104MIT OR Apache-2.0
masl_runtimeHigh-performance Compiled ReBAC Virtual Machine (CRVM) and execution runtime for the Maduka Authorization Specification Language…104MIT
atomr-infer-runtime-candlePure-Rust transformer inference for atomr-infer via the candle crate family. Feature-gated; default-features-off compiles to a…103Apache-2.0
haagenti-distributedDistributed inference across multiple nodes with tensor parallelism103MIT OR Apache-2.0
kojinAsync distributed task queue for Rust — like Celery, BullMQ, Sidekiq, but for Rust102MIT OR Apache-2.0
ctfsCausal consistency at nanosecond latency. Algebraic invariants without coordination.102MIT
tickparseBlazing-fast streaming CSV parser for financial tick data — mmap, zero-copy, parallel102non-standard
fast-down-gui超级快的下载器图形化界面102MIT
worklane-memoryIn-memory worklane broker for development, tests, and examples.102MIT OR Apache-2.0
dactor-mockMock multi-node cluster for testing dactor actor systems100MIT
atomr-infer-pipelineatomr-streams integration for atomr-infer; re-exports the atomr-accel-patterns blueprints (DynamicBatchingServer,…99Apache-2.0
supersonicA one-stop rust crate for high-speed, high-performance, high-concurrency data-structures.98MIT OR Apache-2.0
rust_bus_macrosbus — Lightweight CQRS Library for Rust98MIT
solti-tlsSolti SDK shared TLS / mTLS configuration.97Apache-2.0
atomr-infer-runtime-mistralrsMistral.rs runner for atomr-infer. Wraps mistralrs::TextModelBuilder + Model behind the ModelRunner trait with token-streaming.97Apache-2.0
subetha-sidecarSidecar control plane for CXC / SubEtha adaptive primitives: per-NUMA scan thread, policy dispatch, SidecarBox RAII,…97MIT
rusty-rapidgzipStreaming, parallel gzip decoder. Inspired by rapidgzip / pugz.96MIT
subetha-pointersExotic pointer types for the CXC / SubEtha IPC stack: content-prefix (Umbra), bloom-filtered, log2-strided, multi-segment,…96MIT
rt-ringLock-free SPSC ring buffer with overwrite-oldest semantics for real-time applications96MIT OR Apache-2.0
constraint-crdtCRDT-backed constraint states for distributed fleet consensus96MIT
atomr-infer-runtime-cudarcDirect CUDA kernel dispatch for atomr-infer via cudarc + atomr-accel-cuda. Feature-gated; default-features-off compiles to a…95Apache-2.0
scope-spawnstructured concurrency management for tokio tasks95MIT OR Apache-2.0
rskit-dagDAG task orchestrator with parallel execution95MIT
chump-cost-trackerPer-session cost visibility for LLM agents: atomic per-provider call counts, token tallies (input/output), and Tavily credit…94Apache-2.0
fluxion-errorError types for the Fluxion reactive streaming library94Apache-2.0
struct-threadsA simple library providing a Thread extension trait for Runnable tasks.94MIT
taktora-connector-mqttMQTT reference connector for the taktora-connector framework. Implements BB_0004 (FEAT_0036).94Apache-2.0 OR MIT
async-selectorFast and flexible asynchronous task selector94MIT
operese-dagxA minimal, type-safe, runtime-agnostic async DAG (Directed Acyclic Graph) executor with compile-time cycle prevention and true…92MIT
atomr-inferMulti-runtime GPU + remote inference as a supervised actor system on atomr. Single-crate rollup that re-exports per-runtime…92Apache-2.0
llm-agent-runtimeUnified Tokio agent runtime -- orchestration, memory, knowledge graph, and ReAct loop in one crate91MIT
solti-discoverSolti SDK agent-registration and heartbeat client for the Podium control-plane.91Apache-2.0
chump-cancel-registryTiny global registry of per-request CancellationToken handles, keyed by string id. Pair with tokio_util::sync::CancellationToken…90Apache-2.0
solti-apiSolti SDK HTTP/JSON and gRPC API layer.90Apache-2.0
crawnA utility for web crawling and scraping90MIT
tensor-wasm-coreFoundational types, errors, metrics, and telemetry shared by every TensorWasm crate.90Apache-2.0
stagecraft-macrosMacros for stagecraft90Apache-2.0
atomr-patternsDDD/CQRS pattern library for atomr — aggregates, readers, projections, sagas, outbox, ACL.90Apache-2.0
pacta-memoryIn-memory Pacta Registry backend with real lease and lapse semantics.89MIT OR Apache-2.0
cpu_bindBind threads to idlest CPU core / 将线程绑定到最空闲 CPU 核心89MulanPSL-2.0
sayiir-d1Cloudflare D1 (SQLite) persistence backend for Sayiir workflow engine89MIT
tarnishProcess isolation library with automatic panic recovery for running untrusted Rust code88MIT
subetha-cxcMMF-backed cross-process IPC primitives for SubEtha: SharedRing, SharedHashMap, SharedRWLock, SharedSemaphore, SharedLRUCache,…88MIT
llamSafe, Go-style Rust bindings for the LLAM runtime88Apache-2.0
dash_cacheContains multiple LRU cache implementations, including a sharded LRU cache implementation for concurrent performance, DashCache.87MIT
ipc-lockCross-process named locks using std::fs::File::lock() on Unix and CreateMutexW on Windows87MIT
kathputliMinimal typed-mailbox actor framework over Tokio — actors respond to messages like puppets to strings87MIT OR Apache-2.0
pacta-conformanceBackend-agnostic conformance suite for Pacta Registry implementations.86MIT OR Apache-2.0
pactaCurated entrypoint for Pacta: a thin, durable lifecycle contract you compose.86MIT OR Apache-2.0
agilityA powerful and elegant reactive programming library for Rust, inspired by category theory85MIT OR Apache-2.0
dactor-ractorRactor adapter for the dactor distributed actor framework85MIT
maestro-rsA lightweight, fast, and ergonomic framework for building TCP & UDP servers in Rust with zero boilerplate.85MIT
rakka-telemetryTracing, metrics, and exporter probes for rakka — actors, dead letters, cluster, sharding, persistence, remote, streams, and…85Apache-2.0
wombatkv-coreCore types, errors, and shared primitives for WombatKV (object-storage-native KV cache system for LLM inference). Leaf crate, no…85Apache-2.0
wombatkv-radixIn-RAM radix tree + SlateDB-backed L1 metadata index for WombatKV. Implements the longest-prefix lookup over content-addressed KV…85Apache-2.0
wombatkv-storeObject-store backend (S3 / MinIO / R2 / GCS) for WombatKV. Async writes, sync reads, per-namespace LRU eviction with CAS safety.85Apache-2.0
synchronizeSynchronization types which may or may not be useful84MIT OR Apache-2.0
stream-dupDuplicate a single Stream into multiple identical Streams83Apache-2.0 OR MIT
philiprehberger-parallelEasy parallel iteration — par_map, par_filter, par_for_each with progress and error collection83MIT
theater-handler-podmanPodman container handler for Theater WebAssembly runtime83Apache-2.0
enough-ffiC FFI helpers for the enough cooperative cancellation trait82MIT OR Apache-2.0
boson-corePortable Boson types, QueueBackend port, and identity hooks81MIT
tg-rcore-tutorial-sync-T3L8Synchronization primitives for rCore tutorial OS, including mutex, semaphore, and condvar.81GPL-3.0
rust-tokio-supervisorA Rust tokio supervisor with declarative task supervision, restart policy, shutdown coordination, and observability.81MIT
oxifasterA high-performance concurrent key-value store and log engine in Rust81MIT
luxpoolA lightweight, zero-dependency thread pool and dynamic task queue.81MIT OR Apache-2.0
lucioleActor runtime + DAG execution engine. WASM-safe, deadlock-aware, with pipe_to, WaitGraph, and streaming pipelines.81MIT
avx-runtimeAVX Runtime - Native async runtime built from scratch to replace Tokio with work-stealing scheduler, epoll/kqueue/IOCP, and…80MIT OR Apache-2.0
kojin-sqsAWS SQS broker for the kojin task queue80MIT OR Apache-2.0
lock-dbLock manager and deadlock detection for Rust databases - row/range locks, multiple granularities, and wait-for cycle detection.80Apache-2.0 OR MIT
rbufferLock-free fixed-size SPSC and MPSC ring buffers for low-latency messaging.80MIT
atomr-accel-cutlassCUTLASS kernel-template instantiation via NVRTC for atomr-accel. Provides GEMM, grouped GEMM, implicit-GEMM convolution, and EVT…79Apache-2.0
beetry-engineInternal beetry crate. For the public API, check the beetry crate.78MIT
atomr-accel-telemetryGPU observability for atomr-accel: NVTX ranges, NVML metrics actor, and CUPTI activity tracing. Implements the KernelTrace hooks…78Apache-2.0
traceforge-macrosTraceForge is a model checker for concurrent and distributed programs written in Rust78Apache-2.0
rakka-accel-patternsUniversal GPU actor blueprints for rakka-accel-cuda: DynamicBatchingServer, InferenceCascade, ModelReplicaPool,…78Apache-2.0
diamond-types-extendedUnified CRDT library with ergonomic API - fork of diamond-types78ISC
cdptAn automatic, safe, and concurrent garbage collector for Rust78MIT OR Apache-2.0
atomr-accel-flashattnFlashAttention v2 + v3 kernel templates for atomr-accel — fp16/bf16/fp8, causal, varlen, ALiBi, sliding window, sink tokens,…77Apache-2.0
beetry-editor-frontendInternal beetry crate. For the public API, check the beetry crate.77MIT
rumpsteak-lean-bridgeLean verification bridge for Rumpsteak session types77MIT
youpipeHigh-performance data-first pipelines with fused CPU stages and streaming async IO77Apache-2.0
crayon-rsA small coordinator-based distributed task runtime76MIT
rdirstat-coreParallel directory scanner and snapshot pipeline behind the rdirstat TUI/GUI76MIT
chenhe-tg-rcore-tutorial-syncSynchronization primitives for rCore tutorial OS, including mutex, semaphore, and condvar.75GPL-3.0
memkit-asyncAsync-aware memory allocators for memkit75MPL-2.0
rs-singleflightAsync single-flight request coalescing for Rust.74BSD-3-Clause
firq-towerTower middleware integration for Firq scheduling74MIT OR Apache-2.0
adze-concurrency-caps-coreConcurrency cap primitives for bounded parallel execution.74MIT OR Apache-2.0
arctic-mapLock-free adaptive radix tree74MIT OR Apache-2.0