Module sync

Source
Expand description

Synchronous implementation of the batched queue.

This module provides a thread-safe implementation using crossbeam_channel for communication and parking_lot::Mutex for low-contention locking. It is designed for high-throughput scenarios where items need to be processed in batches.

Structsยง

BatchedQueue
A thread-safe, high-performance queue that automatically batches items.
BatchedQueueSender
A sender handle for adding items to a batched queue.