Concurrency 3,422 crates

jobsysLockless Work Stealing Job System4,320MITConcurrency deferred-referenceA deferred reference is not an actual reference, it is merely a smart pointer tied to the lifetime of the location it points to.4,319MITConcurrencyData structures mcmpA small buffer thread safe with multiple producer and multiple consumer allowed4,317MITAlgorithmsConcurrency nexus-channelHigh-performance lock-free SPSC channel for low-latency systems4,315MIT OR Apache-2.0ConcurrencyData structures focoTopic-based strongly typed pubsub for no_std rust4,300BSD-3-ClauseConcurrencyEmbedded development wagGo like sync.WaitGroup implementation in Rust. (sync/async)4,299MIT OR Apache-2.0AsynchronousConcurrency nexus-rtSingle-threaded, event-driven runtime primitives with pre-resolved dispatch4,291MIT OR Apache-2.0ConcurrencyData structures hadron-clientThe Hadron Rust client library.4,287MIT/Apache-2.0API bindingsConcurrency atomr-clusterMembership, gossip, reachability, vector clocks, and split-brain resolvers for atomr clusters.4,276Apache-2.0ConcurrencyNetwork programming rust_diDI — Dependency Injection for Rust4,273MITConcurrencyConfiguration dsonA delta-state CRDT implementation4,263MIT OR Apache-2.0ConcurrencyData structures libtortillasAn asynchronous library based on the actor model for interacting with the BitTorrent protocol4,261MPL-2.0ConcurrencyNetwork programming meslin-deriveErgonomic messaging for Rust4,257MIT OR Apache-2.0AsynchronousConcurrency tangeScalable Task-based Parallelism Framework4,246Apache-2.0/MITConcurrency atomr-persistenceEvent sourcing for atomr — `Eventsourced` trait, recovery permitter, async snapshotter, persistent FSM, at-least-once delivery.4,244Apache-2.0ConcurrencyDatabase interfaces async-opsUse std::ops traits with Futures4,220MIT OR Apache-2.0AsynchronousConcurrency babbuild a bus - low-level components for your next message bus4,220MITConcurrencyData structures pubsub-busThread-safe one-to-many publish-subscribe event system. Simple and easy to use. It just works (hopefully).4,211MITAsynchronousConcurrency testtoolsHelpers for eliminating boilerplate code in tests4,2080BSDAsynchronousConcurrency pbrt-r3A Rust implementation of pbrt-v34,176BSD-2-ClauseCommand line utilitiesConcurrency atomr-distributed-dataConvergent replicated data types (CRDTs) over a atomr cluster — counters, sets, maps, registers, replicator.4,174Apache-2.0ConcurrencyData structures rayon-macroMacros enabling parallelism using the rayon crate4,163Apache-2.0 OR MITConcurrency linchIn development4,133MITAsynchronousConcurrency protexProTex (Process Mutex) concurrency in process level4,130MITConcurrency scambioSafe and efficient value exchanges between endpoint pairs.4,114BlueOak-1.0.0AsynchronousConcurrency shared-resource-pool-builderCreate thread pools with a shared resource.4,111MITConcurrency stateful_async_workerAsynchronous stateful worker threads utilizable as futures4,104MITAsynchronousConcurrency electrologicaHigh performance concurrent primitives for Rust.4,102Apache-2.0AlgorithmsConcurrency rayonzipMake zip archives with concurrent compression using rayon4,090MITCompressionConcurrency threadaloneMake any value Send + Sync but only available on its original thread. Don't use on multi-threaded environments!4,089MIT OR Apache-2.0ConcurrencyRust patterns futex-queueAn efficient MPSC queue with timer capability based on Linux futex. Suitable for real-time applications.4,077Apache-2.0 OR MITConcurrencyData structures napmapAsync HashMap that halts requester tasks until the requested data is accessible4,049MITAsynchronousConcurrency locknessTODO4,039Apache-2.0AsynchronousConcurrency onetimeOnetime (aka. oneshot) async spsc channel4,031Apache-2.0 OR MITAsynchronousConcurrency rs2-streamA high-performance, production-ready async streaming library for Rust.4,024Apache-2.0AsynchronousConcurrency rsplA stream processor language.4,021GPL-3.0-or-laterAsynchronousCompilers riderbounded executor for tokio; limit the count of tasks running 🚦4,020non-standardConcurrency urcusafe wrapper of the memb variant of the userspace RCU library4,019LGPL-2.1-or-laterConcurrencyMemory management node-replicationAn operation-log based approach that transform single-threaded data structures into concurrent, replicated structures.4,015MIT OR Apache-2.0AlgorithmsConcurrency thread_lakeA very high level thread pool manager4,014non-standardConcurrency ziporaHigh-performance Rust implementation providing advanced data structures and compression algorithms with memory safety guarantees.…4,005non-standardAlgorithmsCompression emu_glslA toolkit for GLSL-Rust interop3,996MITComputer visionConcurrency simple-left-rightLockfree, realtime safe and copy-free Synchronisation3,996MIT OR Apache-2.0Concurrency rtrb-basedropA fork of the `rtrb` crate that uses basedrop's Shared pointer in place of Arc3,994MIT OR Apache-2.0ConcurrencyData structures async-redis-lockA simple and easy-to-use asynchronous redis distributed lock implementation based on tokio and redis-rs.3,979MITCachingConcurrency momenlow overhead thread pool3,978AGPL-3.0-or-laterConcurrency atomr-macrosProcedural macros for atomr — `#[derive(Actor)]`, `props!`, `#[derive(Receive)]`.3,969Apache-2.0ConcurrencyRust patterns net-melMélodium network utilities library3,969EUPL-1.2AsynchronousCompilers csplibImplementation of CSP for concurrent programming.3,966MITConcurrency portable_async_sleepA portable async sleep function for Rust3,960MIT OR Apache-2.0AsynchronousConcurrency atomr-streamsTyped reactive streams DSL for atomr — Source / Flow / Sink, junctions, framing, kill switches, hubs, stream refs.3,960Apache-2.0AsynchronousConcurrency scrappy_doA concurrent asynchronous webscraping framework.3,954non-standardAsynchronousConcurrency expire_cacheHigh-performance generational cache for Rust / 高性能分代缓存3,953MulanPSL-2.0AsynchronousCaching neuron-rsAn actor system for building reactive, concurrent, and resilient distributed services3,953MIT OR Apache-2.0AsynchronousConcurrency terminusdmTerminus Download Manager. Download files, resume interrupted downloads, and keep a history of your downloads - within terminal…3,951GPL-3.0-or-laterAsynchronousCommand line utilities linux-rtic-macrosProcedural macros of the linux-rtic crate3,949Apache-2.0 OR MITConcurrencyData structures atomr-infer-coreFoundation crate for atomr-infer — typed errors, deployment value object, ModelRunner trait, batch primitives.3,947Apache-2.0AsynchronousConcurrency matrix_operations_cudaA library to perform matrix operations using cuda3,946MITAlgorithmsConcurrency bsallocA simple general-purpose allocator used to bootstrap other allocators.3,940Apache-2.0ConcurrencyMemory management refptrInherently reference counted structs3,927MITConcurrencyData structures thereA library for planning and executing commands on local and remote hosts.3,922MITAsynchronousConcurrency rshmemWin32 shared memory with safe wrapper for allocating buffers3,919GPL-2.0AsynchronousConcurrency hyperi-rustlibThere's plenty of sage advice out there about how to run Rust services in production at scale — config cascades, structured…3,902BUSL-1.1AsynchronousConcurrency text-melMélodium text utilities library3,898EUPL-1.2AsynchronousCompilers bufchanA simple buffered MPSC channel3,894MITConcurrencyData structures fuel-core-client-extExtension trait for fuel-core-client3,894BUSL-1.1ConcurrencyCryptography::Cryptocurrencies melodium-shareMélodium language parsing and semantic analyser3,894EUPL-1.2AsynchronousCompilers dialectic-tokio-serdeA backend builder for the Dialectic crate using Serde serialization over Tokio transport3,887MITAsynchronousConcurrency atomr-cluster-shardingSharded entities for atomr — allocation strategies, rebalance, three-phase handoff, remember-entities.3,877Apache-2.0ConcurrencyNetwork programming atomr-cluster-metricsAdaptive load balancing using cluster-wide metrics for atomr.3,871Apache-2.0ConcurrencyNetwork programming scrummageFight over OS process prioritisation3,870MIT OR Apache-2.0 OR ZlibConcurrencyOperating systems mogulAgnosticly helps to manage concurrent versions of things3,846MIT OR Apache-2.0ConcurrencyData structures spinoutA thread-safe clonable and mutable smart-pointer akin to `Arc<Mutex<T>>`, using spin-lock instead of system futex.3,840MIT/Apache-2.0ConcurrencyData structures datacake-lmdbA pre-built implementation of datacake's Storage trait using LMDB.3,838MITConcurrencyData structures atomr-telemetryTracing, metrics, and exporter probes for atomr — actors, dead letters, cluster, sharding, persistence, remote, streams, and…3,835Apache-2.0ConcurrencyDevelopment tools::Profiling epoch-dbAn intelligent, persistent, and concurrent key-value store for Rust, designed to manage data with a lifecycle through frequency…3,827MIT OR Apache-2.0CachingConcurrency asyncuteasyncute (async execute) can execute async futures globally without per-executor queues.3,823GPL-3.0AsynchronousConcurrency atomic-try-updatePrimitives that make it easy to implement correct lock-free algorithms3,803MITAlgorithmsConcurrency task_scopeasynchronous runtime extension for supporting Structured Concurrency with task spawning3,802MIT OR Apache-2.0AsynchronousConcurrency lock_poolRobust, efficient, high performance, asynchronous object pooling3,798MIT OR Apache-2.0AsynchronousConcurrency sync-utilsA bunch of utilities in async-await and blocking context.3,795MITAsynchronousConcurrency with_daemonAn async client-daemon abstraction framework3,792MIT OR Apache-2.0AsynchronousCaching ur-scriptUR e-series controller written in rust. Designed to be deployable on embedded systems without access to std.3,791CC-BY-NC-4.0ConcurrencyData structures consumeMemory order consume for when it's known that the compiler can't elide the dependency3,773MITAlgorithmsConcurrency yaaf-macrosProcedural macros for using YAAF3,761Apache-2.0AsynchronousConcurrency wasm_safe_mutexA suite of WebAssembly-safe synchronization primitives that paper over platform-specific locking constraints.3,759MIT OR Apache-2.0AsynchronousConcurrency lf-queueA lock-free multi-producer multi-consumer unbounded queue.3,758MITConcurrencyData structures clhlockAn implementation of Craig and, indenpendently, Magnussen, Landin, and Hagersten queue lock for mutual exclusion, referred to as…3,746MIT OR Apache-2.0AlgorithmsConcurrency bauFun, simple signaling library3,703MIT OR Apache-2.0Concurrency task_forgeA flexible and simple task pool for asynchronous execution3,698MITAsynchronousConcurrency supervisedTyped supervision for long-lived Tokio services.3,694MIT OR Apache-2.0AsynchronousConcurrency telltale-runtimeChoreographic programming for Telltale - effect-based distributed protocols3,691MIT OR Apache-2.0AsynchronousConcurrency lf-shardedringbufAn async, lock-free, sharded, cache-aware SPSC/MPSC/MPMC ring buffer in Rust.3,683MITConcurrency nexus-poolHigh-performance object pools for low latency systems3,683MIT OR Apache-2.0ConcurrencyData structures linux-rticA Real-Time Interrupt-driven Concurrency (RTIC) implementation for Linux3,678Apache-2.0 OR MITConcurrencyData structures d3A framework for server development3,675MIT OR Apache-2.0AsynchronousConcurrency cc-queueFatourou and Kallimanis's CC Queue, ccqueue, an unbounded, concurrent blocking queue faster than the classic Michael & Scott…3,673MITConcurrencyData structures object-spaceAn object store library for highly concurrent program written in Rust.3,666Apache-2.0/MITConcurrencyData structures ringkernel-coreCore traits and types for RingKernel GPU-native actor system3,657Apache-2.0AsynchronousConcurrency pool_barrierA barrier for blocking a main thread until the completion of work which has been offloaded to worker threads, without blocking…3,656MIT/Apache-2.0AsynchronousConcurrency smart_channelA simple channel subscription system3,653MITAsynchronousConcurrency rtactorAn Actor framework specially designed for Real-Time constrained use cases.3,644MITAsynchronousConcurrency anvil_dban embedded key-value store3,632MITConcurrencyDatabase interfaces atomr-agents-coreCore types for the atomr-agents framework: ids, budgets, context, events, errors.3,625Apache-2.0AsynchronousConcurrency sortlockA crate providing ordered locking.3,593BSD-3-ClauseConcurrency shared-containerA unified abstraction for shared data access in both multi-threaded and single-threaded environments3,591MITConcurrencyRust patterns nexus-slotHigh-performance conflation slots (SPSC + SPMC) for latest-value-wins scenarios3,580MIT OR Apache-2.0ConcurrencyData structures work-melMélodium distant work library3,574EUPL-1.2AsynchronousCompilers nexus-idHigh-performance ID generators for low-latency systems3,570MIT OR Apache-2.0ConcurrencyData structures quartzPort of the original Java Quartz Scheduler to Rust3,565Apache-2.0AsynchronousConcurrency mfioFlexible completion I/O primitives3,558MITAsynchronousConcurrency dagxA minimal, type-safe, runtime-agnostic async DAG (Directed Acyclic Graph) executor with compile-time cycle prevention and true…3,557MITAsynchronousConcurrency par_sliceSlices that may be accessed from multiple threads with different levels of safety3,556MITConcurrency dynamic_oclDynamically-loaded OpenCL bindings3,547Apache-2.0API bindingsConcurrency static_locksThe `parking_lot` locks but usable in statics and const fn.3,543Apache-2.0/MITConcurrency seshA library for deadlock-free session-typed communication.3,523MITConcurrency transaction-stmtransaction abstraction of stm3,514MITConcurrencyRust patterns blocking_semaphoreA simple and performant blocking semaphore.3,511MIT OR Apache-2.0Concurrency rocksdb-rayonAn implementation of rayon's ParallelIterator for rocksdb.3,510GPL-3.0-or-laterConcurrencyDatabase interfaces ogre-stream-ext`futures` shortcuts with ergonomic extensions to unlock the full power of Streams in Rust3,510UnlicenseAlgorithmsAsynchronous tower-resilience-adaptiveAdaptive concurrency limiter for Tower services using AIMD and Vegas algorithms3,500MIT OR Apache-2.0AsynchronousConcurrency taskvisorIn-process Tokio task supervisor with retries, reliable outcomes, and per-key queue/replace/reject admission3,492Apache-2.0AsynchronousConcurrency phylactery_macroA set of macros to accompany the `phylactery` crate.3,482MITConcurrencyData structures asygnal[WIP] Async-first signal handling, such as ctrl-c.3,464MIT OR Apache-2.0AsynchronousConcurrency boltThe package provides a hierarchical read-write lock.3,452Apache-2.0 OR MITAsynchronousConcurrency bagpipeA concurrent bag datastructure.3,444Apache-2.0AlgorithmsConcurrency rayon-attrProvides macro attributes that translate existing code to be parallel using rayon.3,444Apache-2.0/MITConcurrency atomiqConvenient tool for atomics in Rust.3,440MPL-2.0ConcurrencyRust patterns arrow-rayonUse parallel iterators for Apache Arrow with rayon3,432UnlicenseConcurrency bevy_impulseReactive programming and workflow execution for bevy3,414Apache-2.0AsynchronousConcurrency async-jobsAsynchronous job orchestration for Rust3,412MIT OR Apache-2.0AlgorithmsAsynchronous blasoxide-mtmultithreading for blasoxide3,408MITConcurrency ringbuf-basedropA fork of the `ringbuf` crate that uses basedrop's Shared pointer in place of Arc3,405MIT/Apache-2.0ConcurrencyData structures nexus-statsFixed-memory, zero-allocation streaming statistics for real-time systems3,396MIT OR Apache-2.0ConcurrencyData structures async-task-ffiTask abstraction for building executors3,388Apache-2.0/MITAsynchronousConcurrency distrib-melMélodium distribution library3,382EUPL-1.2AsynchronousCompilers snarcSendable Non-Atomically Reference Counted3,375MITAsynchronousConcurrency sendptrConvenient cross-thread raw pointer usage / 方便跨线程用裸指针3,366MulanPSL-2.0ConcurrencyData structures luminal_rtA DLL-boundary safe async runtime with tokio-compatible API3,366MITAsynchronousConcurrency rds_lockA simple and easy-to-use asynchronous redis distributed read-write lock implementation based on tokio and redis-rs.3,353MITCachingConcurrency melodium-distributionMélodium language parsing and semantic analyser3,340EUPL-1.2AsynchronousCompilers mpi-fork-fnspMessage Passing Interface bindings for Rust (FORK)3,339MIT/Apache-2.0Concurrency faucetBack-pressured MPMC queue that can be drained after signaling completion3,337MIT OR Apache-2.0Concurrency yaksMinimalistic framework for automatic multithreading of hecs via rayon3,334MIT OR Apache-2.0ConcurrencyGame engines mulaShare expensive computation with various requesters3,332MITConcurrency nexus-smartptrInline smart pointers for trait objects — Flat (inline-only) and Flex (inline with heap fallback)3,327MIT OR Apache-2.0ConcurrencyData structures shared_channelMulti-producer, multi-consumer FIFO queue communication primitives.3,325MITAsynchronousConcurrency futures-prioCombinator to set priority of Futures3,322MIT OR Apache-2.0AsynchronousConcurrency slurmplusA command-line tool for nice interaction with the Slurm workload manager.3,318MITConcurrencyScience araeCursed data structures3,307MITConcurrencyData structures rust-task-queueProduction-ready Redis task queue with intelligent auto-scaling, Actix Web integration, and enterprise-grade observability for…3,292MIT OR Apache-2.0AsynchronousConcurrency wsio-serverEvent-driven WebSocket server for ws.io with namespaces and room broadcasting.3,292MITAsynchronousConcurrency bndpresbufchBounds-preserving channel for passing buffers.3,2890BSDConcurrencyData structures runner_qDurable activity queue and worker system3,282MITAsynchronousConcurrency drone-tisl-mapTexas Instruments SimpleLink™ peripheral mappings for Drone, an Embedded Operating System.3,272MIT OR Apache-2.0AsynchronousConcurrency schedulesA lightweight Rust library for managing operations across multiple time scales3,262MITConcurrencyDate and time dagerCrate to create and execute a graph of nodes.3,231MPL-2.0Concurrency adirectorasynchronous tokio task spawner with a limited size3,230non-standardConcurrency par-array-initConvenience functions for initializing arrays in parallel.3,229MITConcurrencyData structures blocksrDrew's Rust library for (clang/objc) blocks3,220MIT OR Apache-2.0AsynchronousConcurrency flussStream processing framework3,216MITAsynchronousConcurrency sovran-arcMemory management swift-isms brought to Rust3,216MITConcurrencyMemory management dialectic-tokio-mpscA backend for the Dialectic crate using Tokio's MPSC channels3,210MITAsynchronousConcurrency cicd-melMélodium CI/CD library3,210EUPL-1.2AsynchronousCompilers hiatusDebug concurrent programs by choosing specific execution traces3,207Apache-2.0ConcurrencyDevelopment tools::Debugging simple_event_mapa simple event map based on channels, provides a receiver that is either blocking or async3,203MIT OR Apache-2.0Concurrency is_main_threadA simply tool to check if current thread is the main one.3,197Apache-2.0Concurrency distributed-lock-coreCore traits and types for distributed locks3,192MITAsynchronousConcurrency pakr-fsmTemplate to implement finite-state-machines3,172BSD-2-ClauseAsynchronousConcurrency i2o2A io_uring based IO executor for sync and async runtimes3,165MITAsynchronousConcurrency liblgmp-sysRaw bindings to the LGMP library by gnif3,155GPL-2.0ConcurrencyExternal FFI bindings breaker-machinesHigh-performance circuit breaker with fallback support and rate-based thresholds3,154MITConcurrency orbAn abstraction for writing runtime agnostic async code. Orb provides interfaces to adapt different async runtimes like smol and…3,152MITConcurrencyNetwork programming wasserglasA fixed size thread-safe object pool with automatic reattachment3,151MIT/Apache-2.0ConcurrencyData structures wsio-coreShared packet, event, and task primitives for ws.io.3,147MITAsynchronousConcurrency futures-cputaskTurn synchronous CPU-bound tasks into futures3,142MIT OR Apache-2.0AsynchronousConcurrency run-downAn implementation of run-down protection in rust.3,141MITConcurrencyMemory management async-blocking-stdiostd::io::std{in(), out(), err()} but async3,136GPL-3.0-or-laterAsynchronousConcurrency mlua-isleThread-isolated Lua VM with cancellation, async coroutines, and connection pool for mlua3,120MIT OR Apache-2.0API bindingsConcurrency hordea horde of threads3,115MIT OR Apache-2.0ConcurrencyData structures hv-cellA no-std port of the `atomic_refcell` crate with additional `Arc`-centric functionality3,113MIT OR Apache-2.0ConcurrencyNo standard library log-melMélodium logging library3,112EUPL-1.2AsynchronousCompilers pkcs12crackerHigh-performance, multi-threaded PKCS#12 password cracker supporting dictionary, pattern-based, and brute force attacks3,111MITAuthenticationCommand line utilities ringalEfficient ring allocator for short-lived buffers.3,110MITConcurrencyMemory management intid-allocatorTypes to allocate and free integer ids3,099MIT OR Apache-2.0ConcurrencyData structures async-once-watchAsynchronous and shareable container which value is set once.3,091MITConcurrency shakespeareAn actor framework3,079MIT OR Apache-2.0AsynchronousConcurrency ascoltAsync runtime-agnostic actor framework3,075non-standardAsynchronousConcurrency xutexan extremely fast async mutex with alternative sync API3,074MITAlgorithmsAsynchronous blocking_poolA thread pool for running synchronous I/O in asynchronous applications3,061MIT OR Apache-2.0AsynchronousConcurrency ach-poolAtomic Channel3,059non-standardConcurrency stageAn ergonomic, composable Actor Model, designed for painless concurrency3,054non-standardAsynchronousConcurrency wralWrite ahead logging for durability3,050MITConcurrencyDatabase interfaces ccdA windows simple, fast chrome_cookie_decryptor3,044MITAsynchronousConcurrency chtshRust CLI for interacting with https://cht.sh3,042MITAsynchronousCommand line utilities appendvecA concurrent append-only container of immutable values3,038MIT OR Apache-2.0AlgorithmsConcurrency simple-asyncVery simple async runtime for Rust3,034MITAsynchronousConcurrency telltale-choreographyChoreographic programming for Telltale - effect-based distributed protocols3,030MIT OR Apache-2.0AsynchronousConcurrency api-rate-limiterA simple rate limiter for Rust APIs3,026MITConcurrencyWeb programming tensrA high-performance, cross-platform, multi-backend tensor/array library for Rust3,026MIT OR Apache-2.0ConcurrencyData structures