spsc-ring-threadsafe 0.0.5

A thread-safe SPSC queue, implemented on a ring buffer written in C

spsc-ring-threadsafe

Lockless, thread-safe single-producer single-consumer FIFO queue for Python — implemented on a ring buffer in C.

Design

Built on a Lamport ring buffer with C11 _Atomic read/write indexes (acquire/release ordering). Producer and consumer never contend with eachother.

Features:

• single producer, single consumer FIFO semantics
• lockless (no mutexes or spinlocks)
• non-blocking / async-friendly
• suitable for shared memory and IPC
• compatible with no-GIL & subinterpreters
• low overhead, especially for small messages
• up to 100x faster than multiprocessing.Queue in the standard library

Benchmarks

---

Quick Start

import spsc_ring_threadsafe as srt

buf = bytearray(4096)
srt.init(buf)  # initialize as ring buffer

item = b"this is a bytestring message"
srt.put(buf, item)

result = srt.get(buf)
print(result.decode())

Output:

this is a bytestring message

---

API Reference

Exceptions

Exception	Raised when
spsc_ring_threadsafe.QueueFullError	put() called on a full buffer
spsc_ring_threadsafe.QueueEmptyError	get() called on an empty buffer

Functions

spsc_ring_threadsafe.init(buf)

Initialize a mutable buffer as a ring buffer (this function sets the read + write indexes to zero).

Parameter	Description
buf	Mutable buffer-compatible object (bytearray, memoryview, etc.). Size must be power of two anywhere from 256 bytes to 2 GiB.

⚠️ Thread safety: Initialization is not thread-safe. Initialize once before any concurrent access, or provide your own synchronization.

---

spsc_ring_threadsafe.put(buf, item)

Insert an item into the ring buffer. Non-blocking.

Parameter	Description
buf	Mutable buffer-compatible object. Size must be power of two anywhere from 256 bytes to 2 GiB.
item	Buffer-compatible object to insert

Raises: QueueFullError if the buffer has insufficient space.

⚠️ Buffer must be zeroed or initialized before use.

---

spsc_ring_threadsafe.get(buf)

Remove and return an item from the ring buffer. Non-blocking.

Parameter	Description
buf	Mutable buffer-compatible object. Size must be power of two anywhere from 256 bytes to 2 GiB.

Returns: Buffer-compatible object containing the message.

Raises: QueueEmptyError if no message is available.

⚠️ Buffer must be zeroed or initialized before use.

---

Installation

uv add spsc-ring-threadsafe

or

pip install spsc-ring-threadsafe

---

Development

Run tests

uv run python -m unittest discover -s tests -v

Run benchmarks

uv pip install -e . --force-reinstall --no-deps
uv run python tests/benchmark.py

Run dev script

uv pip install -e . --force-reinstall --no-deps
uv run python tests/dev.py

---

LLM Usage Disclosure

Tests and benchmarks were written with assistance from AI models. All C code is written by hand.