Muzuka-c

This is a collection of some modern skills for multithreading and concurrency in C++

• Mutex
  • SpinlockMutex: A simple mutex implementation based on std::atomic_flag::test_and_set
  • DataMutex: A Rust-style mutex in C++
• Task Queue
  • SimpleSerialTaskQueue: A simple serial queue implementation
  • TaskQueue: A general task queue running tasks in parallel. The concept is similar to SimpleSerialTaskQueue but it runs the tasks in several threads at the same time instead of running them sequentially
• Ring Buffer
  • SPSCRingBuffer: A thread-safe single-producer-single-consumer circular buffer

Run the demo

Run run.sh <FOLDER_NAME> to play the examples, where the <FOLDER_NAME> is mutex, task_queue, or ring_buffer. Or you can simply go to those folder then build examples by running make and clean them by make clean.

Concurrent programming references

• Review of many Mutex implementations
• sysprog21 / concurrent-programs

Lock-free

• An Introduction to Lock-Free Programming
• A Fast Lock-Free Queue for C++
• Data Plane Development Kit (DPDK)'s Ring Library
  • Code here
• Linux Lockless Ring Buffer Design

Code Examples

SPSC

• cameron314 / readerwriterqueue
• facebook / folly / ProducerConsumerQueue

MPMC

• cameron314 / concurrentqueue
• facebook / folly / MPMCQueue
• Ring Implementation in FreeBSD*
  • bufring.h in FreeBSD
  • bufring.c in FreeBSD

MPSC

• rmind / ringbuf
• lemonrock / lock-free-multi-producer-single-consumer-ring-buffer