#concurrency

Self growing / shrinking ThreadPool implementation based on crossbeam's multi-producer multi-consumer channels that enables awaiting the result of a task and offers async support.

Concurrent Processing

Concurrent non-blank line counter for source code directories.

该仓库未发布描述。

Jump Consistent Hash implementation for Rust

Fast, lightweight async primitives: SPSC channel, oneshot, notify, and atomic waker.

该仓库未发布描述。

A correctness-critical payment engine that moves value between wallets while surviving worker crashes, network partitions, and duplicate retries

Owned mutex guards for refcounted mutexes.

Cells and slices that are accessible from multiple threads

Faster.Map — A high-performance SIMD-accelerated .NET dictionary and hashmap designed for extreme speed, scalability, and low memory overhead. Ideal for real-time systems and game engines.

A lightweight lock protected by an atomic boolean.

Fast Go Event Queue with Partitioned Topics & Broadcast Channels 🚀

该仓库未发布描述。

Fiber-based structured concurrency using cooperative multitasking

BEAM friendly spinlocks for Elixir/Erlang

Better reference counted strings for Rust

Package bigbuff implements a one-many ordered queue producer-consumer pattern + utilities.

Message-passing channels for async communication, inspired by Go and Rust

Production-inspired distributed background job processing engine built with Go, Redis, and PostgreSQL. Features worker pools, retries, DLQ, crash recovery, scheduling, observability, idempotency, and backpressure handling.

Fiber plugin for the Testo testing framework (split-published from php-testo/testo)