cameron314/readerwriterqueue
Readerwriterqueue
هذا المشروع عبارة عن طابور متزامن (concurrent queue) أحادي المنتج وأحادي المستهلك لـ C++ مصمم لتبادل البيانات بدون أقفال (lock-free) بين الخيوط (threads). يوفر آلية آمنة للخيوط لنقل البيانات دون استخدام كائنات المزامنة (mutexes) أو الأقفال.
تم تنفيذ الطابور كمخزن مؤقت دائري متصل يدعم نمو السعة الديناميكي لمنع فقدان البيانات عند وصول الطابور إلى حده الأقصى. يستخدم المزامنة الذرية وإدارة الفهرس بدون انتظار (wait-free) لتنسيق الوصول إلى البيانات بين خيوط الكتابة والقراءة.
تغطي المكتبة الاتصال بين الخيوط وإدارة المخزن المؤقت، وتوفر عمليات إخراج (dequeue) حاصرة وغير حاصرة لإدارة كيفية انتظار الخيوط المستهلكة للبيانات الجديدة.
Features
- Single-Producer Single-Consumer Queues - Implements a specialized single-producer single-consumer model to eliminate contention and minimize synchronization overhead.
- Lock-Free Thread Communication - Provides high-performance primitives for transferring data between threads without the overhead of mutex locking.
- Thread-Safe Communication Channels - Offers a high-performance C++ data structure for safe information passing between concurrent threads.
- Circular Memory Buffers - Uses a ring-based memory layout to efficiently reuse space for data exchange between threads.
- Contiguous Memory Buffers - Allocates elements in flat, contiguous memory blocks to optimize cache locality and reduce latency.
- Lock-Free - Employs atomic primitives and memory barriers to ensure thread-safe data exchange without mutex locks.
- Buffer Capacity Growth - Supports dynamic allocation of larger contiguous blocks when the queue reaches capacity to prevent data loss.
- Wait-Free Synchronization - Manages head and tail indices using atomic integers to guarantee progress for both producer and consumer.
- Dynamic Buffer Management - Manages queue elements by combining upfront memory reservation with dynamic capacity expansion.
- Low Latency Messaging - Minimizes message delivery delay between threads by avoiding traditional mutex synchronization.
- Inter-Thread Buffer Management - Handles data streams between threads using a contiguous memory buffer that grows as demand increases.
- Blocking Synchronization - Implements mechanisms to suspend consumer threads until the producer adds new data to the queue.
- Concurrency and Parallelism - Fast single-producer single-consumer lock-free queue.
