Concurrency 3,422 crates

sharded_ringbufA Tokio async, sharded SPSC/MPSC/MPMC ring buffer in Rust.2,171MITConcurrency crossflow_deriveProcedural macros for crossflow2,168Apache-2.0AsynchronousConcurrency distrustc-clientA Rust-compatible distcc implementation2,167MITCommand line utilitiesCompilers mogaA multi-objective genetic algorithm framework2,165MITAlgorithmsConcurrency distrustc-serverA Rust-compatible distcc implementation2,156MITCommand line utilitiesCompilers carpetA thread-safe, fully-parallel directed graph2,151MITConcurrencyData structures rayon-core-wasmCore APIs for Rayon2,149MIT OR Apache-2.0Concurrency noxu-utilInternal utilities for Noxu DB (LSN, VLSN, byte encoding, stats framework)2,148Apache-2.0 OR MITConcurrencyData structures mini_executorThe smallest, simplest Rust task executor using Tokio runtime2,144MITAsynchronousConcurrency murmerA distributed actor framework for Rust2,143MIT OR Apache-2.0AsynchronousConcurrency concurrencykitModern concurrency primitives and building blocks for high performance applications2,141MITConcurrencyData structures fqA fast and simple ring-buffer-based single-producer, single-consumer queue with no dependencies. You can use this to write Rust…2,141MIT OR LGPL-3.0-or-laterAsynchronousConcurrency atomiclock_asyncA simple async lock2,138MIT OR Apache-2.0AsynchronousConcurrency noxu-syncNoxu DB synchronization primitives: futex-based Mutex/RwLock/Condvar2,138Apache-2.0 OR MITConcurrencyData structures dcontextDistributed context propagation for Rust — scoped, type-safe, serializable2,137MITConcurrencyNetwork programming wait_on_addressCross-platform atomic wait and wake (aka futex) functionality.2,132BSD-2-ClauseConcurrencyNo standard library local-spawn-poolSpawn `!Send` futures in a pool and await for all of them to finish. Standalone alternative to `tokio::task::LocalSet`.2,125MITAsynchronousConcurrency thread_binderBind rayon pools to limit numa effects2,123Apache-2.0/MITConcurrency pick_fastHigh-performance weighted random load balancer for selecting low-latency nodes with smooth weight updates. /…2,119MulanPSL-2.0AlgorithmsConcurrency lz_stream_ioAsyncRead and AsyncWrite implementations for Streams and Sinks respectively2,117MITAsynchronousConcurrency sentinel-towerSentinel middleware for Tower2,117Apache-2.0ConcurrencyDevelopment tools concurrent-poolA concurrent object pool.2,114MIT OR Apache-2.0ConcurrencyData structures fluxion_macroProc-macro crate for fluxion.2,111MIT OR Apache-2.0Concurrency derivable-object-pool-macrosMacros for the derivable-object-pool crate2,106MIT OR Apache-2.0ConcurrencyData structures casial-coreConsciousness-aware context coordination engine - The Casial substrate for paradox-resilient AI agent context management and…2,104MIT OR Apache-2.0AlgorithmsConcurrency transactionalA simple optimistic lock-free confirmation-based transactional model for Rust.2,102non-standardAlgorithmsCaching synchrotronA single-threaded busy-wait executor based on futures2,098MIT/Apache-2.0Concurrency locklessnessComposable, lock-free, allocation-light data structures2,089MIT OR Apache-2.0AsynchronousConcurrency llkv-transactionTransaction management and MVCC for the LLKV toolkit.2,085Apache-2.0ConcurrencyDatabase implementations amadeus-parquet-deriveApache Parquet Derive Macro implementation.2,083Apache-2.0ConcurrencyDatabase interfaces orb-tokioorb interface adaptor for tokio ecology. Orb is an abstraction for writing runtime agnostic async code.2,079MITConcurrencyNetwork programming atomiq-deriveDerive macros for atomiq.2,078MPL-2.0ConcurrencyRust patterns atomic-progressA high-performance, cloneable progress tracker with minimal locking overhead.2,076MITCommand-line interfaceConcurrency tasksA task parallel library in Rust similar to TPL in C#2,060MITAsynchronousConcurrency dtactDtact: A non-preemptive, stackful coroutine runtime featuring a lock-free context arena, P2P mesh scheduling, and…2,060MIT or Apache-2.0AsynchronousConcurrency threadsafe_zmqThread-safe ZeroMQ wrapper with sync and async support2,058Apache-2.0AsynchronousConcurrency waitqNo-std, no-alloc async waker queue optimized for `!Send` tasks.2,053MITConcurrencyData structures okv_rocksdbA versatile key-value storage library2,037MIT OR Apache-2.0API bindingsConcurrency atomic_struct_coreCore library for atomic_struct procedural macro2,035MITConcurrencyData structures local-runtimeThread-local async runtime2,034MIT OR Apache-2.0AsynchronousConcurrency generic-containerAbstract over "containers" that hold a T, such as a T itself, Box<T>, or Arc<Mutex<T>>2,032MIT OR Apache-2.0ConcurrencyMemory management raceStaggered async task executor with race semantics / 阶梯式异步任务执行器，具备竞赛语义2,030MulanPSL-2.0AlgorithmsAsynchronous telltale-bridgeLean verification bridge for Telltale session types2,030MITConcurrencyDevelopment tools squall-errorAgentic error2,024MITAsynchronousConcurrency polyesterParallel iterator adaptors that accept arbitrary iterators2,021MPL-2.0ConcurrencyRust patterns wasm_safe_threadCross-platform std::thread + std::sync replacement for native and wasm32.2,019MIT OR Apache-2.0AsynchronousConcurrency counter6464bit increase-only atomic counter for everywhere2,010MIT/Apache-2.0Concurrency noxu-latchLatching primitives for Noxu DB (shared/exclusive latches)2,004Apache-2.0 OR MITConcurrencyData structures kevy-ringLock-free bounded SPSC ring buffer. Pure Rust.2,001Apache-2.0 OR MITConcurrencyData structures crossflowReactive programming and workflow engine in bevy2,000Apache-2.0AsynchronousConcurrency noxu-configConfiguration parameter system for Noxu DB1,998Apache-2.0 OR MITConcurrencyData structures async_buf_reader_utilsAdds additional functionality to the async-std crate for BufReader1,995Apache-2.0/MITAsynchronousConcurrency takeawayAn efficient work-stealing task queue with prioritization and batching.1,983MIT OR Apache-2.0ConcurrencyData structures atomr-persistence-queryTagged event-stream queries over atomr journals.1,982Apache-2.0ConcurrencyDatabase interfaces open-coroutine-iouringThe io_uring support for open-coroutine1,966LGPL-3.0 OR Apache-2.0AsynchronousConcurrency streamhouse-deriveThe derive macro crate for streamhouse1,965MIT OR Apache-2.0CachingConcurrency async-ecsAsync Parallel Entity Component System for Rust1,954Apache-2.0/MITConcurrencyGame engines vec_parallelConstruct your Vec in parallel1,946MIT OR Apache-2.0AsynchronousConcurrency jobflowExecutes jobs in order1,945MIT OR Apache-2.0Concurrency rusty-variationA library for deadlock-free session-typed communication.1,941MITConcurrency telltale-searchDeterministic weighted-graph search substrate for Telltale1,936MIT OR Apache-2.0AlgorithmsConcurrency async-watch2Async watch channel1,930Apache-2.0 OR MITAsynchronousConcurrency scoped-join-setA scoped variant of tokio::task::JoinSet for spawning non-'static futures.1,926MIT OR Apache-2.0AsynchronousConcurrency noxu-logLog-structured storage engine for Noxu DB1,925Apache-2.0 OR MITConcurrencyData structures komora-syncSynchronization structures for the komora db project1,924MIT OR Apache-2.0AlgorithmsCaching dtact-macrosMacro utilities for Dtact: A non-preemptive, stackful coroutine runtime featuring a lock-free context arena, P2P mesh scheduling,…1,918MIT or Apache-2.0AsynchronousConcurrency tioYet another async io solution.1,915MITAsynchronousConcurrency atomic-destroyAn value which can be atomically read and destroyed; like an atomic Option.1,914MIT OR Apache-2.0ConcurrencyData structures ctrlc_fnonceWrapper for ctrlc to execute a FnOnce and exit the process upon Ctrl-C.1,908Apache-2.0Concurrency shutter-gateSimple test utility to panic when spawned threads are blocked too long1,907MIT/Apache-2.0Concurrency implicit-awaitImplicitly await calls returning Future impls1,907CC0-1.0AsynchronousConcurrency rtipcReal-Time IPC, based on a zero-copy, wait-free circular message queue implementation1,902MIT OR Apache-2.0Concurrency sqlite-mumusqlite-mumu is a plugin for the mumu ecosystem1,899MIT OR Apache-2.0ConcurrencyData structures concurrent-eventAn event system which invokes event handlers concurrently.1,898MIT OR Apache-2.0Concurrency cnrAn operation-log based approach for data replication.1,897MIT OR Apache-2.0AlgorithmsConcurrency carmenA crate for conduction depth-first searches and backtracking algorithms.1,885MITAlgorithmsConcurrency threadsTraits to abstract thread-pools1,884Apache-2.0 OR MITAsynchronousConcurrency atomic-utilsnon global, configurable and fast concurrent resource reclamation1,883MITAlgorithmsConcurrency gothack-future-parking_lotAn "as simple as possible" Future implementation for parking_lot1,879Apache-2.0/MITAsynchronousConcurrency arc-disk-cacheConcurrently Readable Disk Cache1,875MPL-2.0CachingConcurrency cocoroA more type-safe take on Rust stackless coroutines1,875non-standardAsynchronousConcurrency cachemapA concurrent insert-only hashmap for caching values1,874MITCachingConcurrency fsdr-blocksBuilding blocks for FutureSDR signal processing library for SDR and real-time DSP.1,872Apache-2.0AsynchronousConcurrency qubit-atomicUser-friendly atomic operations wrapper providing JDK-like atomic API1,872Apache-2.0ConcurrencyData structures tokio-actorsOTP-faithful actors for Tokio: panic-visible supervision, restart strategies, and Erlang-grade lifecycle semantics with zero…1,865MIT OR Apache-2.0AsynchronousConcurrency parcollCollections for parallel computing, such as SPSC, SPMC, and MPSC and MPMC queues.1,853MITConcurrencyData structures swymTransactional memory for rust1,851MITConcurrencyData structures atomic_structProc-macro crate to derive atomic struct with Arc<tokio::Mutex<T>> fields1,844MITConcurrencyData structures noxu-treeB-tree implementation for Noxu DB1,842Apache-2.0 OR MITConcurrencyData structures actyA lightweight, async actor framework built on Tokio.1,835MIT OR Apache-2.0AsynchronousConcurrency swym-htmHardware transactional memory for rust1,831MITConcurrencyData structures numaperf-coreCore types and error handling for the numaperf NUMA runtime1,830MIT OR Apache-2.0ConcurrencyMemory management kestrel-protocol-timer基于时间轮（Timing Wheel）算法的高性能异步定时器系统1,829MIT OR Apache-2.0AsynchronousConcurrency fused-readerThis crate provides fused reader type that if writer thread dies while holding armed fuse the reader will get BrokenPipe error1,823MITConcurrency employerSpawn worker threads and check on them later1,821MITAsynchronousConcurrency thidNo-std, no-alloc thread IDs and thread-locals.1,820MITConcurrencyData structures sovran-stateSimple state management for Rust1,815MITConcurrencyData structures system-graphsystem-graph is an experimental alternative for shred's Dispatcher.1,814MIT/Apache-2.0Concurrency rabia-coreCore SMR traits, types, and consensus algorithm implementation for the Rabia State Machine Replication protocol1,809Apache-2.0AlgorithmsConcurrency ferrompiA safe, generic Rust wrapper for MPI with support for MPI 4.0+ features, shared memory windows, and hybrid MPI+OpenMP1,809MIT OR Apache-2.0ConcurrencyScience gwyhgwyh is a sweet gossip library1,805LGPL-3.0-onlyAsynchronousConcurrency orb-smolorb interface adaptor for smol-rs ecology. Orb is an abstraction for writing runtime agnostic async code.1,805MITConcurrencyNetwork programming dialectic-tokio-serde-jsonA backend for the Dialectic crate using JSON serialization over Tokio transport1,796MITAsynchronousConcurrency loatesLoates is a load testing framework, with focus on ease of use and flexiblity.1,794MITConcurrencyDevelopment tools maximImplements a highly-scalable and ergonomic actor system for Rust based on the best of Erlang / Elixir and Akka. A fork of the…1,794Apache-2.0AsynchronousConcurrency observable-property-tokioA thread-safe, async-compatible observable property implementation for Rust using Tokio1,791MITAsynchronousConcurrency chattyA Chat Server written in Rust1,788MITAsynchronousConcurrency batch_queueA single-producer single-consumer Rust queue with smart batching1,787MIT OR Apache-2.0Concurrency numaperf-topoNUMA topology discovery and CPU locality mapping1,778MIT OR Apache-2.0ConcurrencyMemory management yaambocrate for concurrent skip lists1,771MITConcurrencyData structures rayon-macro-hackImplementation details of rayon-macro1,769Apache-2.0 OR MITConcurrency telltale-lean-bridgeLean verification bridge for Telltale session types1,767MITConcurrencyDevelopment tools safe_oclZero-cost wrapper types for safe OpenCL1,764MITAsynchronousConcurrency kevy-rtkevy thread-per-core shared-nothing runtime — pure Rust, zero deps.1,762Apache-2.0 OR MITConcurrencyDatabase implementations drop_workerTools for worker threads1,758MIT OR Apache-2.0Concurrency atomicsBasic utils for concurrent programming. Backoff, spinlocks, seqlock, atomic type wrappers.1,758Unlicense OR MITConcurrencyData structures spawn_timeoutCall a subroutine after a constant time interval1,756MITAccessibilityAsynchronous noxu-txnTransaction management and locking for Noxu DB1,753Apache-2.0 OR MITConcurrencyData structures biased-rcA reference counting type biased toward the creating thread1,747MITConcurrencyData structures asynciterAsynchronous iterator.1,744MIT OR Apache-2.0AsynchronousConcurrency rasmData-Oriented 3D WebGPU Game Engine Written in Rust WebAssembly.1,744GPL-3.0-or-laterConcurrencyGame engines weavegraphGraph-driven, concurrent agent workflow framework with versioned state, deterministic barrier merges, and rich diagnostics.1,743Apache-2.0AlgorithmsConcurrency atomr-accelBackend-agnostic compute-acceleration core. Defines the AccelBackend trait, AccelRef<T> typed pointers, AccelError enum, and…1,737Apache-2.0AsynchronousConcurrency rust-cli-commandsrust-cli-commands1,737Apache-2.0 OR MITAsynchronousConcurrency primal-crossbeamAn interface to primal using crossbeam's channels. This allows the worker thread to stop once the receiver is dropped, for…1,736CC0-1.0ConcurrencyMathematics jottyJoTTy is an embeddable distributed processing framework for both short and long running batch jobs1,736GPL-3.0-onlyAsynchronousConcurrency global-channelSimple global channels.1,736MIT OR Apache-2.0Concurrency dekkerImplementation of Dekker's algorithm for mutual exclusion.1,734MIT OR Apache-2.0AlgorithmsConcurrency walrus-rustA high-performance Write-Ahead Log (WAL) implementation in Rust1,732MITConcurrencyData structures closure-futureEasily run closures on thread pools and turn their result into Futures1,729BSD-3-ClauseAsynchronousConcurrency drone-riscvRISC-V platform crate for Drone, an Embedded Operating System.1,727MIT OR Apache-2.0AsynchronousConcurrency suspend-channelChannel and stream implementations1,725MIT OR Apache-2.0AsynchronousConcurrency file-crawlerA fast, concurrent, async and customisable file crawler1,719MITConcurrency ruv-swarm-transportTransport layer for RUV-FANN swarm communication with WebSocket and SharedMemory support1,712MIT OR Apache-2.0ConcurrencyNetwork programming rusty_junctionsJoin Pattern implementation in Rust.1,705MITConcurrency daemonbit-rundirCross-platform daemon lifecycle primitives1,703MIT OR Apache-2.0API bindingsAsynchronous kayakA Raft implementation for intuitive usage1,702Apache-2.0 OR MITAlgorithmsAsynchronous atomr-accel-cudaGPU acceleration via the actor model. Wraps NVIDIA CUDA libraries (cuBLAS, cuDNN, cuFFT, cuRAND, cuSOLVER, cuSPARSE, cuTENSOR,…1,701Apache-2.0AsynchronousConcurrency shm-primitivesLock-free primitives for shared memory IPC: BipBuffer, slot metadata, and OS-level doorbell/mmap1,699MIT OR Apache-2.0ConcurrencyMemory management dashmap_with_out_t_map_traitBlazing fast concurrent HashMap for Rust.1,698MITAlgorithmsConcurrency masstreeA high-performance concurrent ordered map (trie of B+trees)1,697MITConcurrencyData structures supergreenLib of common utils for cargo-green & rustcbuildx1,696MITCachingCompilers netty-rsNetty-rs allows exposes a simple-to-use API used to create stateful application level network protocols as both a client or…1,695MIT OR Apache-2.0AsynchronousConcurrency rsa-solverUses various attacks against RSA to efficiently brute-force m from c, e, and n.1,693CC0-1.0AlgorithmsConcurrency rumpsteakSession types for asynchronous communication between multiple parties.1,693MITAsynchronousConcurrency phoenix-tlsUtilities for creating always present thread locals.1,693MIT/Apache-2.0Concurrency futex_channelA faster drop in replacemet for std channel1,693MIT/Apache-2.0ConcurrencyOperating systems psbusGeneric Publish / Subscribe model for application messaging1,692MITAsynchronousConcurrency zestors-requestA fast, flexible and extensible actor-framework.1,691MIT OR Apache-2.0Concurrency noxu-cleanerLog file garbage collection for Noxu DB1,688Apache-2.0 OR MITConcurrencyData structures tensr_proc_macrosProcedural macros for the Tensr multidimensional array library1,684MIT OR Apache-2.0ConcurrencyData structures app-queueIn-app persistent queue for asynchronous jobs1,683Apache-2.0AsynchronousConcurrency atomic_sibling_counterA shared counter that allows parallel threads/tasks to check how many siblings they have. The counter is atomic and threads/tasks…1,683MIT OR Apache-2.0AsynchronousConcurrency cirqueUnidirectional, circular, lock/wait-free SPSC queue with unbounded capacity.1,681MPL-2.0ConcurrencyData structures rw_leaseFast Reader-Writer lock with reader draining support. Based on a single (parameterisable) atomic usize.1,679MPL-2.0AlgorithmsConcurrency atomic_pincellThreadsafe pinnable RefCell1,677Apache-2.0/MITAsynchronousConcurrency surtgis-parallelParallel processing strategies for SurtGis1,677MIT OR Apache-2.0ConcurrencyScience::Geospatial kwaitA wait library for retry/wait/loop inspired by K8s1,676non-standardConcurrencyDevelopment tools tokio-async-ioPort of the `smol::Async` to tokio 0.21,674Apache-2.0AsynchronousConcurrency nexus-netLow-latency networking primitives: buffers, TLS codec, wire abstractions.1,671MIT OR Apache-2.0ConcurrencyData structures hloclHigh-level bindings for OpenCL1,670MIT OR Apache-2.0API bindingsAsynchronous mongo_syncinstant coding answers via the command line(just like howdoi)1,667GPL-3.0Command line utilitiesConcurrency evelynSimple event distribution library1,667MITConcurrency hat-trie-cacheA high-performance HAT-trie implementation with integrated quick-cache support for concurrent operations and binary encoding…1,666MIT OR Apache-2.0CachingConcurrency meio-httpSet of connectors for MEIO framework1,664MIT/Apache-2.0Concurrency limiteronUnified flow control framework for Rust1,663MITConcurrencyWeb programming etcdmqLightweight Message Queue backed by etcd1,658Apache-2.0Concurrency theater-serverHTTP server for Theater actor system management1,657Apache-2.0ConcurrencyDevelopment tools stakker_async_awaitStakker-based executor for Rust async/await code1,653MIT/Apache-2.0AsynchronousConcurrency zingA fast, fiber-based job system1,652MITConcurrencyGame development spmc_ringThread-safe no_std ring buffer1,651BSD-3-ClauseConcurrencyEmbedded development prideA distributed event-streaming platform1,649Apache-2.0ConcurrencyDatabase implementations tc-serverTinyChain's cluster server logic, including peer discovery and replication1,649Apache-2.0ConcurrencyData structures qmiAn ECS with too much macro usage1,648MITAlgorithmsConcurrency atomic-array-rsDefines several array types in which elements may be updated atomically. Intended to provide atomic array types similar to those…1,647MIT/Apache-2.0AsynchronousConcurrency run-themA CLI to launch a single command with many workers, serializing the output1,646MITCommand line utilitiesConcurrency nylonAn async/.await based job system where futures live in fibers that are run on core-pinned threads.1,646MITAsynchronousConcurrency ya-ring-bufYet Another Ring Buffer. SPSC channel with direct access for bytes/Copy.1,644MITConcurrencyData structures arccellAn attempt at AtomicReferences in Rust1,643MIT/Apache-2.0Concurrency channel-drainDrain channels with simple syntax1,643ZlibConcurrency meio-extraExamples of extending meio1,639Apache-2.0Concurrency hybrid-lockA hybrid lock with optimistic locking1,637MIT OR Apache-2.0Concurrency ddf-simple-websocketsFast and efficient WebSocket server with an easy API. 'simple-websockets' quit compiling properly hence this fork.1,619MITAsynchronousConcurrency pythonic_global_lockA globally locked mutex1,618MITConcurrency ferris_chats_serverThis binary provides a server for ferris_chat.1,617GPL-3.0AsynchronousCommand line utilities apidaesweet btree collections1,615MIT OR Apache-2.0ConcurrencyData structures shardizeproc macro that generates code to create a sharded form of an existing container1,615MIT OR Apache-2.0ConcurrencyRust patterns rayon-progress-barSimple work-stealing parallelism for Rust1,611MIT OR Apache-2.0Concurrency ezcacheEasy and flexible cache library for Rust1,611GPL-2.0-onlyCachingConcurrency computation-processA Rust library for defining stateful computations (and generators) that support suspend/resume, interleaving, cancellation and…1,611MITAlgorithmsConcurrency stdin_receiverA structure to help read from stdin in a separate thread, and a method to halt execution.1,610MITCommand-line interfaceConcurrency rusty-junctions-macroLibrary Generation and Client Macro API for rusty-junctions.1,610MITConcurrency read-cellRead-only Cell counterpart1,609MIT OR Apache-2.0ConcurrencyNo standard library mem_fileA wrapper around native shared memory for Linux and Windows1,609MIT OR Apache-2.0AsynchronousConcurrency burstyTest support for exarcebating contention in multi-threaded code1,607MIT OR Apache-2.0ConcurrencyDevelopment tools::Testing zlayer-consensusShared Raft consensus library built on openraft 0.9 for ZLayer and Zatabase1,607Apache-2.0ConcurrencyNetwork programming elasticqThread-safe, dynamically resizable queues with lock-based and lock-free implementations for high-throughput scenarios1,606MITAsynchronousConcurrency atomic-busAtomic MPMC Bus1,603MIT OR Apache-2.0Concurrency noxu-recoveryCheckpoint-based crash recovery for Noxu DB1,603Apache-2.0 OR MITConcurrencyData structures sync_toolsa collection of libraries to promote object reuse1,601MITConcurrencyData structures