Concurrency 3,422 crates

momentumA simple wrapper for the Momentum API3,022MITAsynchronousConcurrency dbLightweight high-performance pure-rust transactional embedded database.3,017MIT OR Apache-2.0AlgorithmsCaching parking_monitorParking-lot-flavored monitor synchronization construct3,009MITConcurrency intel-tsx-hleAtomic intrinsics for HLE (Hardware Lock Elision) on some Intel Skylake CPUs3,008MITConcurrencyHardware support nexus-actor-message-derive-rsA Rust crate for Actors message3,006MIT OR Apache-2.0AsynchronousConcurrency simple-websocketa simple WebSockets implementation, to be used in clients and servers3,005Apache-2.0AsynchronousConcurrency concgcAn experiment. concurrent gc3,000MPL-2.0ConcurrencyNo standard library cooperA simple, in-process, async Actor library for Rust.2,998MITAsynchronousConcurrency sharded-logA sharded log for multi-threaded logging2,993GPL-3.0ConcurrencyDatabase implementations linux_onceA Linux-optimized drop-in replacement for std::sync::Once2,985MITNFAConcurrencyOperating systems::Linux APIs ampscasync multi-producer single-consumer channel2,981MIT OR Apache-2.0AsynchronousConcurrency channel_pipesPerform operations on broadcast queues.2,974MITConcurrency dashtableA concurrent raw hash table2,974MITAlgorithmsConcurrency converge-coreConverge Agent OS - correctness-first, context-driven multi-agent runtime2,974MITAlgorithmsConcurrency global-executorConfigure a global executor you can reuse everywhere2,973Apache-2.0 OR MITAsynchronousConcurrency taskiasync task DAG execution2,960non-standardAsynchronousConcurrency callysto-avroAvro serde for Callysto Stream Processing Framework2,958Apache-2.0AsynchronousConcurrency yaafYet Another Actor Framework2,954Apache-2.0AsynchronousConcurrency rayoffrayon but it's map-reduce2,940MIT OR Apache-2.0Concurrency deloxideDeloxide scrubs your threads clean by detecting deadlocks in real time—keeping your system smooth, safe, and corrosion-free. 🦀🧼🔒2,939MIT OR Apache-2.0ConcurrencyDevelopment tools smol-axumIntegrations between `smol` and `axum`2,931MIT OR Apache-2.0AsynchronousConcurrency crossbeam-skiplist-fdA long-term maintained forked version of the crossbeam-skiplist for supporting more flexible key comparison customization.2,924MIT OR Apache-2.0AlgorithmsConcurrency redis_ipcSimple crate for ipc (inter-process communication) and service-to-service communication based on redis.2,920MITAPI bindingsCaching flume-overwriteA library for sending values to a flume bounded channel, overwriting the oldest values if the channel is full.2,920MITConcurrency fibre_cacheBest in-class comprehensive, most flexible, high-performance, concurrent multi-mode sync/async caching library for Rust. It…2,919MPL-2.0AsynchronousCaching sorted-channelsorted message-based communication channel2,913MIT OR Apache-2.0Concurrency hyaline-smrGarbage Collector(Hyaline- Safe Memory Reclaimation) for lock free data structures2,913Apache-2.0/MITConcurrencyMemory management pmrsRust support to process mining functions. Includes a library and a small cli-interface.2,899LGPL-3.0-onlyCommand line utilitiesConcurrency robtRead only, immutable Btree for indexing key,value2,896MITConcurrencyData structures tagged-rendezvousRendezvous hashing with support for tag-based exclusions2,895MIT OR Apache-2.0ConcurrencyData structures provenantA version of Arc that can free memory while weak pointers exist by probabilistically tracking provenace.2,895MITConcurrencyData structures lock_manyRetry-based locking multiple mutexes at once.2,891MITConcurrency read-write-storeA concurrent, unordered collection for Rust, where each element has an internally generated ID and a read-write lock.2,890MITAlgorithmsConcurrency asparitAsync Parallel Iterators for Rust2,888Apache-2.0/MITConcurrency roundaboutAn message oriented concurrent runtime2,886MIT OR Apache-2.0AsynchronousConcurrency fusabi-hostShared host/runtime utilities for Fusabi across Scarab/Tolaria/Hibana/Phage2,884MIT OR Apache-2.0API bindingsConcurrency dart_portdart_port.rs2,878UnlicenseAPI bindingsAsynchronous nexus-stats-coreCore types and utilities shared across nexus-stats subcrates2,877MIT OR Apache-2.0ConcurrencyData structures taskqueueParallel execution of the task queue with the ability to add new tasks inside the running tasks2,871MITConcurrencyData structures ref-portalsSafely use (stack) references outside their original scope2,869MIT OR Apache-2.0ConcurrencyRust patterns elk-mqA Message Queue implementation in rust, using Redis as a communication medium.2,869Apache-2.0AsynchronousConcurrency codas-flowLow-latency, high-throughput bounded queues ("data flows") for (a)synchronous and event-driven systems.2,869MITConcurrencyNetwork programming todc-utilsUtilities for building and testing distributed systems.2,868MITAlgorithmsConcurrency nexus-rateRate limiting and flow control primitives for real-time systems2,864MIT OR Apache-2.0ConcurrencyData structures syncbufAppend-only data structures with lock-free thread-safety and constant-time indexing2,863MITConcurrencyData structures notifier_hubA simple cannal subscribtion system2,862MITAsynchronousConcurrency majraDistributed queue & multiplex engine — pub/sub, priority queues, relay, IPC, heartbeat, and rate limiting for Rust2,862GPL-3.0-onlyAsynchronousConcurrency pinnableA Mutex that can be pinned2,852MIT OR Apache-2.0Concurrency lock_freedomThis crate provides concurrent data structures and a solution to the ABA problem as an alternative of hazard pointers2,845MITAlgorithmsConcurrency sarlaccThread-safe lock-free interning of data2,841MITCachingConcurrency magic-ring-bufferA magic ring buffer (also known as a virtual ring buffer, VRB, or mirrored buffer) which is lock-free for multiple producers and…2,840MITConcurrencyData structures threadbeamA simple, specialized channel type for beaming data out of a newly spawned thread2,838MIT OR Apache-2.0ConcurrencyNo standard library asynqSimple, reliable & efficient distributed task queue in Rust, inspired by hibiken/asynq2,838MIT OR GPL-3.0AsynchronousConcurrency flourishConvenient and full-featured signals for Rust.2,836MIT OR Apache-2.0AsynchronousCaching thespianAsynchronous actor-based concurrency patterns inspired by Erlang.2,836MIT OR Apache-2.0Concurrency async-ecs-deriveDerive macros for async-ecs crate2,829Apache-2.0/MITConcurrencyGame engines bevy_gpu_compute_coreEmpowering anyone to leverage GPU-acceleration with as little barrier-to-entry as possible2,828MITAPI bindingsConcurrency indexed-poolIndexed object pool for expensive / frequent allocations2,825MITCachingConcurrency derivable-object-poolA thread-safe derivable object pool collection with automatic reusage of objects.2,824MIT OR Apache-2.0ConcurrencyData structures nexus-decimalFixed-point decimal arithmetic with compile-time precision2,820MIT OR Apache-2.0ConcurrencyData structures mwmrA generic optimistic transaction manger, which is ACID, concurrent with SSI (Serializable Snapshot Isolation).2,814Apache-2.0/MITAsynchronousConcurrency open-coroutine-hooksThe syscall hook for open-coroutine2,810LGPL-3.0 OR Apache-2.0AsynchronousConcurrency read_rangeA portable and efficient crate for reading a specific range of bytes from a file. Provides both sync/async APIs and uses…2,809MITAsynchronousConcurrency starpu-sysLow-level bindings to the StarPU runtime2,805MPL-2.0AsynchronousConcurrency whorlWhorl was created to teach you how async executors work in Rust.2,802MITAsynchronousConcurrency melange_db基于 sled 架构深度优化的下一代高性能嵌入式数据库，支持 ARM64 NEON SIMD 优化、多级缓存和布隆过滤器2,802LGPL-3.0ConcurrencyData structures tokio-switching-sleepA tokio Sleep with a switchable state.2,799WTFPLAlgorithmsAsynchronous sentinel-macrosOut-of-the-box attribute macors to ease sentinel usage.2,798Apache-2.0ConcurrencyDevelopment tools steelmillA resource manager (dependency injector / factory) designed for distributed systems and simulation testing2,780MITConcurrencyDatabase implementations implicit-await-macro#[implicit_await] procedural macro implementation2,773CC0-1.0AsynchronousConcurrency conveyor_beltQueue and batch processing library2,765MIT OR Apache-2.0AsynchronousConcurrency uv_patch_packed_simdPortable Packed SIMD vectors. Temporary fork implementing asin and acos for `ultraviolet` to unblock release.2,764MIT/Apache-2.0ConcurrencyData structures lending_thread_poolA thread pool where workers can lend their data to their tasks.2,753MITConcurrency rust_howtoA documentation summary and a compendium of snippets and recipes for the Rust language and ecosystem. Everything you need for…2,748MIT OR Apache-2.0AlgorithmsAsynchronous mycorrhMycorrh is a fast concurrent messaging system for Rust.2,742MITAsynchronousConcurrency send_cellsSafe and unsafe cells implementing Send/Sync2,738MIT OR Apache-2.0ConcurrencyRust patterns libsyncSynchronise stuff2,735MIT OR Apache-2.0AsynchronousConcurrency oneshot-broadcastA oneshot-broadcast channel that broadcasts a value once without cloning it.2,733MIT OR Apache-2.0AsynchronousConcurrency simple-taskA distributed task queue for learning Rust2,730MITConcurrency mula_proc_macroProc macro for Mula, share expensive computation with various requesters2,725MITConcurrency rcu_lista lockless concurrent list implementation2,720LGPL-3.0ConcurrencyData structures prollyAn implementation of the prolly tree data structure2,718Apache-2.0AsynchronousConcurrency daemonbit-coreCross-platform daemon lifecycle primitives2,714MIT OR Apache-2.0API bindingsAsynchronous distributed-lock-redisRedis backend for distributed locks with RedLock algorithm support2,711MITAsynchronousConcurrency multichannelA mpmc priority multi channel with dynamic channel registration and freezing.2,710MIT OR Apache-2.0Concurrency request-channelAsync MPSC request-reponse channel2,709MIT/Apache-2.0AsynchronousConcurrency rayon-wasmSimple work-stealing parallelism for Rust2,704MIT OR Apache-2.0Concurrency ruloomA thin wrapper around 'corosensei' that provides support for stackful coroutines in Rust (like Loom in Java or goroutines in…2,702MIT OR Apache-2.0AsynchronousConcurrency thread-counterA simple way of efficiently keeping track of active threads and waiting for them to exit.2,700MIT OR Apache-2.0Concurrency distributed-lock-postgresPostgreSQL backend for distributed locks using advisory locks2,697MITAsynchronousConcurrency guttersBasic generic functions for building quick and dirty interprocess or network protocols.2,695MITConcurrencyNetwork programming uasyncfast, safe, async executor2,692MITAsynchronousConcurrency primal-tokioAn interface to primal using tokio's streams. This allows the worker to stop once the receiver is dropped, for example.2,686CC0-1.0AsynchronousConcurrency distributed-lock-fileFile system backend for distributed locks using OS-level file locking2,684MITAsynchronousConcurrency address-artisanVanity Bitcoin address generator based on BIP32 extended public keys with GPU acceleration.2,679MITCommand line utilitiesConcurrency flash-mapGPU-native concurrent hash map with bulk-only API. Robin Hood hashing, SoA layout, CUDA kernels. Designed for blockchain state,…2,677MIT OR Apache-2.0ConcurrencyData structures simple_thread_poolA simple thread pool.2,674MITConcurrency theta-flumeA blazingly fast multi-producer channel2,674Apache-2.0/MITConcurrencyData structures distributed-lock-mysqlMySQL backend for distributed locks using GET_LOCK/RELEASE_LOCK functions2,673MITAsynchronousConcurrency network-protocolSecure, high-performance protocol core with backpressure control, structured logging, timeout handling, TLS support, and…2,666Apache-2.0AsynchronousAuthentication distributed-lock-mongoMongoDB backend for distributed locks using atomic updates and TTL indexes2,661MITAsynchronousConcurrency nexus-stats-smoothingAdvanced smoothing algorithms for nexus-stats: KAMA, Holt, Spring, Kalman1d, WindowedMedian2,656MIT OR Apache-2.0ConcurrencyData structures smpscWrappers for tokio's mpsc channels which implement Stream and Sink.2,655MITAsynchronousConcurrency wsio-clientEvent-driven WebSocket client for ws.io.2,653MITAsynchronousConcurrency protoactor-clusterProtoActor implementation in Rust2,650Apache-2.0AsynchronousConcurrency async-refreshCreate values that refresh automatically and asynchronously after a given duration.2,637MITAsynchronousCaching protoactor-remoteProtoActor implementation in Rust2,632Apache-2.0AsynchronousConcurrency disruptor-rsA high-performance ring buffer implementation of the LMAX Disruptor pattern2,631MIT OR Apache-2.0ConcurrencyData structures command_historyA library for managing command history in Rust applications.2,626MIT OR Apache-2.0Concurrency sentoA lock-free, append-only atomic pool.2,624Apache-2.0ConcurrencyData structures bevy_gpu_compute_macroEmpowering anyone to leverage GPU-acceleration with as little barrier-to-entry as possible2,614MITAPI bindingsConcurrency isoprenoidisoprenoid is the signals runtime framework backing flourish.2,608MIT OR Apache-2.0AsynchronousCaching cddA windows simple, fast chrome_cookie_decryptor2,608MITAsynchronousConcurrency relaxedWrappers around Atomics that always use `Ordering::Relaxed`2,606MIT OR Apache-2.0ConcurrencyNo standard library::No dynamic allocation workedRun functions in Web Workers with ease2,605MITConcurrencyWebAssembly melodium-libMélodium library placeholder2,601EUPL-1.2AsynchronousCompilers protoactor-persistenceProtoActor implementation in Rust2,590Apache-2.0AsynchronousConcurrency atomiclockA non-blocking lock that can be used in async contexts2,584MIT OR Apache-2.0ConcurrencyNo standard library prime-formulaHigh-performance prime number generation and constellation finding using novel wheel factorization2,583MITAlgorithmsConcurrency rcursAn oxidized RCU implementation2,579MITConcurrency nexus-stats-regressionOnline regression, learning, and estimation for nexus-stats2,578MIT OR Apache-2.0ConcurrencyData structures actr-runtimeThin business dispatch layer for Actor-RTC — wasm32-compatible2,577Apache-2.0AsynchronousConcurrency dialectic-tokio-serde-bincodeA backend for the Dialectic crate using Bincode serialization over Tokio transport2,577MITAsynchronousConcurrency distributed-lockDistributed locks for Rust with multiple backend support (PostgreSQL, Redis, MySQL, MongoDB, file system)2,577MITAsynchronousConcurrency faaa_queueA really fast unbounded lock-free concurrent queue.2,574MIT OR Apache-2.0ConcurrencyData structures some_local_executorA simple local executor2,563MIT OR Apache-2.0AsynchronousConcurrency rust_busbus — Lightweight CQRS Library for Rust2,560MITConcurrencyConfiguration tcrm-monitorTask dependency management and execution library with parallel processing, real-time monitoring, and runtime control2,557MIT OR Apache-2.0AsynchronousConcurrency transient_dbAn intelligent, persistent, and concurrent key-value store for Rust, designed to manage data with a lifecycle through frequency…2,551MIT OR Apache-2.0CachingConcurrency nolocal-block-onfutures_lite::future::block_on that can run without using thread-locals2,549MPL-2.0AsynchronousConcurrency observable-propertyA thread-safe observable property implementation for Rust2,548MIT OR Apache-2.0ConcurrencyData structures suspend-corePrimitives for parking a thread and awaiting a notification2,545MIT OR Apache-2.0AsynchronousConcurrency dialectic-nullA no-op backend for the Dialectic crate, intended for benchmarking and testing2,539MITAsynchronousConcurrency channelmapA DashMap wrapper over Tokio channels2,535MITAsynchronousConcurrency cobbWIP library to help track down bugs in concurrent algorithms2,533Apache-2.0 OR MIT OR ZlibConcurrencyData structures supply-chain-trust-example-crate-000028More compact and efficient implementations of the standard synchronization primitives.2,531MIT OR Apache-2.0Concurrency eipsEfficient intention-preserving sequence CRDT2,531AGPL-3.0-or-later WITH AdditionRef-Eips-exceptionsConcurrencyData structures nexus-stats-controlAdvanced control and frequency primitives for nexus-stats2,529MIT OR Apache-2.0ConcurrencyData structures circEfficient referenced counted pointers for non-blocking concurrency2,526MIT OR Apache-2.0ConcurrencyMemory management objectpoolYet another lock-free object pool, support no_std2,525MIT OR Apache-2.0ConcurrencyData structures hmi_vue3_tauri_lib_v2面向工业HMI的Tauri后端，内置Modbus任务队列与事件分发2,522MITConcurrencyGUI d-engineLightweight Raft consensus engine - recommended entry point for most users2,519MIT OR Apache-2.0AlgorithmsAsynchronous nexus-stats-detectionAdvanced change detection and signal analysis for nexus-stats2,513MIT OR Apache-2.0ConcurrencyData structures rumpsteak-macrosSession types for asynchronous communication between multiple parties.2,510MITAsynchronousConcurrency async-rayonMix async code with CPU-heavy thread pools using Futures + Rayon2,500MITAsynchronousConcurrency async-poolStatically allocated pool providing a std-like Box, with async functionality.2,484MIT OR Apache-2.0ConcurrencyEmbedded development datacake-clusterEventually consistent state replication as a library (consensus, RPC and conflict resolution) for building your own eventually…2,474MITAsynchronousConcurrency thread-broadcasterA SPMC (Single producer multi consumer) broadcasting channel to broadcast notifications between threads2,470MITAlgorithmsConcurrency async-subscription-mapAsync bookkeeping datastructure for state subscriptions2,464MITAsynchronousConcurrency instance-copy-on-writeA MT-safe copy-on-write implementation for the data structures.2,454MITConcurrency plain-cacheHighly performant thread-safe cache with a focus on simplicity2,451MIT OR Apache-2.0CachingConcurrency nexus-notifyCross-thread event queue with conflation and FIFO delivery2,448MIT OR Apache-2.0ConcurrencyData structures burstqA multi-producer, multi-consumer channel that supports sending or receiving multiple values in a single operation.2,441MITConcurrencyData structures rate_limitersFlexible and easy-to-use Rust library for implementing rate limits.2,438MITAlgorithmsAsynchronous mqbLock free in memory message queue broker2,436MIT OR Apache-2.0AsynchronousConcurrency parcheckTest permutations of concurrent scenarios2,420MITConcurrencyDevelopment tools::Testing bevy_gpu_computeEmpowering anyone to leverage GPU-acceleration with as little barrier-to-entry as possible2,409MITAPI bindingsConcurrency fusabi-plugin-runtimePlugin loader, hot-reload, and runtime for Fusabi plugins with manifest validation and capability enforcement2,409MIT OR Apache-2.0API bindingsConcurrency limqchA channel built on top of limq.2,4070BSDConcurrency camureHigh-performance 1-to-many communication and synchronization primitives using UDP multicast.2,396MIT/Apache-2.0ConcurrencyNetwork programming thread-shareA Rust library for safe and efficient data sharing between threads with zero-copy operations, change detection, and enhanced…2,395MITAsynchronousConcurrency hv-lease-trackerno-std compatible tracking of borrow origins, for providing better diagnostics when implementing interior mutability primitives2,385MIT OR Apache-2.0ConcurrencyData structures coroStackful, first-class asymmetric coroutines.2,378MITConcurrency mtlog-tokioScoped logging for tokio runtimes with support for log files.2,375MITConcurrencyConfiguration hv-atomConvenient abstractions for atomic operations on smart pointer/reference types, based on the `atom` crate2,373MIT OR Apache-2.0ConcurrencyNo standard library okv_memoryA versatile key-value storage library2,373MIT OR Apache-2.0API bindingsConcurrency pin-queueAn unbounded queue using pinned nodes2,372Apache-2.0ConcurrencyData structures pairlockA reader-writer lock with wait-free reads2,371Apache-2.0 / MITConcurrencyData structures periodicallyA library for running tasks on a schedule2,369non-standardConcurrency atomiclock_spinlockA simple spinlock2,364MIT OR Apache-2.0ConcurrencyRust patterns crdt-liteA lightweight, column-based CRDT implementation in Rust2,359MITAlgorithmsConcurrency waitableA synchronized (atomic) value container implementing the Mutex+Condvar pattern for efficient blocking waits2,350MITConcurrency critical-once-cellThread-safe OnceCell and Lazy backed by critical section2,343MPL-2.0ConcurrencyEmbedded development process_anywhereTools for running computer processes locally or remotely via SSH.2,343MIT-0ConcurrencyNetwork programming floxide-macros-supportA directed graph workflow system in Rust2,341MITAsynchronousConcurrency async-duplex-channelAn asynchronous duplex communication channel between multiple clients and a single responder in different asynchronous blocks.2,333MITAsynchronousConcurrency rusty-junctions-library-generation-proc-macroThe Library Generation component of the rusty-junctions-macro crate2,323MITConcurrency pressure-measurement压力测试2,323MIT OR Apache-2.0Command-line interfaceConcurrency wovenA simple set of async combinators, usable in a no_std environment.2,320MIT OR Apache-2.0AsynchronousConcurrency zestors-coreA fast, flexible and extensible actor-framework2,310MIT OR Apache-2.0Concurrency rusty-junctions-client-api-proc-macroA convenient set of procedural macros used as part of the rusty-junctions-macro Client Macro API.2,301MITConcurrency termusixA terminal-based music player with a user-friendly terminal UI, built with Rust.2,296GPL-3.0-or-laterAsynchronousCommand line utilities rusty-junctions-client-api-macroA convenient set of declarative macros used as part of the rusty-junctions-macro Client Macro API.2,294MITConcurrency omango-syncSynchronization utilities2,293MITAlgorithmsConcurrency caxtonA secure WebAssembly runtime for multi-agent systems2,272MIT OR Apache-2.0ConcurrencyNetwork programming lamellar-profLamellar is an asynchronous tasking runtime for HPC systems developed in RUST.2,267non-standardAsynchronousConcurrency atomic_bitfieldA bitfield abstraction for the core atomic types.2,248MITConcurrencyEmbedded development mini-moka-wasmTemporary vendored fork of mini-moka with wasm browser compat patch2,242MIT OR Apache-2.0CachingConcurrency rlockAn easy-to-use Redis-backed lock library providing both async and sync Mutex, RwLock, and others.2,222MITConcurrency set_intervalCall a subroutine at a constant time interval2,220MITAccessibilityAsynchronous consistency_modelA tester for distributed system consistency properties like linearizability and sequential consistency.2,217MIT OR Apache-2.0AlgorithmsConcurrency token-ref-cellInterior mutability cell using an external token to synchronize accesses2,207MITConcurrencyData structures future-by-exampleExamples of common patterns using Future2,200MIT/Apache-2.0AsynchronousConcurrency elfmallocA fast, concurrent, general-purpose allocator.2,197Apache-2.0CachingConcurrency kroosFlexible smart pointer for ?Sized types with customizable reference counting.2,193AGPL-3.0-only ConcurrencyData structures lochanSingle-threaded (!Send), no_std, no-atomics async channels for thread-per-core runtimes: mpsc, mpmc, and oneshot, with…2,191MIT OR Apache-2.0AsynchronousConcurrency promiseryA JavaScript-inspired, ergonomic, and composable Promise type for Rust, supporting background work, chaining, and error handling…2,190MIT OR Apache-2.0AsynchronousConcurrency hj_thread_poolA simple thread pool implementation in Rust.2,186MIT OR Apache-2.0Concurrency dropping-thread-localA dynamically allocated ThreadLocal that ensures destructors are run on thread exit2,180Apache-2.0 OR MITConcurrencyData structures pseudo_poolA pool-like collection that automatically returns objects to the pool & blocks when the pool is empty2,178non-standardConcurrencyData structures