Concurrency

Concurrency

Newest releases

lunaryorn gethostname.rs gethostname() for all platforms. use gethostname::gethostname; println!("Hostname: {:?}", gethostname()); Prior art hostname also prov
 

healeycodes niceware My blog post: Porting Niceware to Rust A Rust port of niceware. Sections of this README have been copied from the original project. This libr
 

mgeier Real-Time Ring Buffer Ripped off of https://github.com/crossbeam-rs/crossbeam/pull/338. Isolated from the rest of crossbeam with git-filter-repo: git-
 

yoshuawuyts Concurrency extensions for Future
 

iximeow regmap some well-known and known-to-be-good computer architectures, such as the Microchip PIC product line, or many of the AVR processor family, were
 

dyedgreen Uncertain<T> Fast and correct computations with uncertain values. When working with values which are not exactly determined, such as sensor data, it c
 

constellation-rs Harmonious distributed data processing & analysis in Rust
 

logicalshift Desync [dependencies] desync = "0.5" Desync is a library for Rust that provides a model of concurrency based around the idea of scheduling operations
 

marthog Software Transactional Memory This library implements software transactional memory, often abbreviated with STM. It is designed closely to haskells ST
 

brunocodutra RingChannel Bounded MPMC channel abstraction on top of a ring buffer. Using RingChannel RingChannel is available on crates.io, simply add it as a depe
 

dbeck acto-rs library This library is a proof of concept, never run in any production setup and is fairly untested. Use at your own risk. You were warned. T
 

gregory-meyer cht cht provides a lockfree hash table that supports fully concurrent lookups, insertions, modifications, and deletions. The table may also be concurr
 

jesperaxelsson rust-intmap Specialized hashmap for u64 keys Might be missing some functionality but you can remove, add, get and clear for now. Be aware that no effo
 

postmates hopper - an unbounded mpsc with bounded memory Hopper provides a version of the rust standard mpsc that is unbounded but consumes a bounded amount of
 

wagnerf42 rayon-logs Presentation rayon-logs is a logging extension for the rayon library. The library is available on crates.io. Logs are performance oriented
 

amethyst shred - Shared resource dispatcher This library allows to dispatch systems, which can have interdependencies, shared and exclusive resource access, in
 

jaredgorski arpx Automate and relate multiple processes. Description arpx runs PROCESSES as they are defined in PROFILES. PROFILES allow for the configuration of
 

stateright Correctly implementing distributed algorithms such as the Paxos and Raft consensus protocols is notoriously difficult due to the presence of nondeterm
 

kimundi scoped-threadpool-rs A library for scoped and cached threadpools. For more details, see the docs. Getting Started scoped-threadpool-rs is available on
 

vertexclique Pillars for Transactional Systems and Data Grids Lever is a library for writing transactional systems (esp. for in-memory data). It consists of variou
 

sagebind Sluice Asynchronous byte buffers and pipes for concurrent I/O programming. Documentation Check the documentation for up-to-date usage and examples. Li
 

ruuda Thread-ID Get a unique ID for the current thread in Rust. For diagnostics and debugging it can often be useful to get an ID that is different for ever
 

lucasem workerpool A worker threadpool used to execute a number of jobs atop stateful workers in parallel. It spawns a specified number of worker threads and
 

rsimmonsjr Implementation of a highly-scalable and ergonomic actor model for Rust Axiom Axiom brings a highly-scalable actor model to the Rust language based on
 

munksgaard Session Types for Rust This is an implementation of session types for Rust. Using this library, you can implement bi-directional process communication
 

abbychau MultiQueue2: Fast MPMC Broadcast Queue MultiQueue2 is a fast bounded mpmc queue that supports broadcast/broadcast style operations MultiQueue was deve
 

eun-ice AtomicRingBuffer / AtomicRingQueue A constant-size almost lock-free concurrent ring buffer Upsides fast, try_push and try_pop are O(1) scales well eve
 

kixiron A multithreaded and single threaded string interner that allows strings to be cached with a minimal memory footprint, associating them with a unique k
 

cogciprocate Qutex Non-thread-blocking queue-backed data locks based on Rust futures. Includes futures capable versions of Mutex and RwLock. Documentation Example
 

jonhoo bus Bus provides a lock-free, bounded, single-producer, multi-consumer, broadcast channel. It uses a circular buffer and atomic instructions to implem
 

cjp10 Object Pool A thread-safe object pool with automatic return and attach/detach semantics The goal of an object pool is to reuse expensive to allocate o
 

agerasev ringbuf Lock-free single-producer single-consumer (SPSC) FIFO ring buffer with direct access to inner data. Overview RingBuffer is the initial structu
 

constellation-rs Harmonious distributed data processing & analysis in Rust 📖 Docs | 🌐 Home | 💬 Chat Amadeus provides: Distributed streams: like Rayon's parallel ite