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