How do I implement a mutex queue in my application?

How do I implement a mutex queue in my application?

To implement a mutex queue, you can use a combination of a queue data structure and a mutex lock to ensure thread safety.

Can you provide a code example for that?

Sure! Here's a simple example in Python using the queue module and threading for the mutex:

import queue
import threading

class MutexQueue:
    def __init__(self):
        self.queue = queue.Queue()
        self.lock = threading.Lock()

    def enqueue(self, item):
        with self.lock:
            self.queue.put(item)

    def dequeue(self):
        with self.lock:
            return self.queue.get()

What if I want to implement it in Java instead?

In Java, you can use ConcurrentLinkedQueue along with a ReentrantLock. Here's a basic example:

import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.locks.ReentrantLock;

public class MutexQueue {
    private ConcurrentLinkedQueue<Object> queue = new ConcurrentLinkedQueue<>();
    private ReentrantLock lock = new ReentrantLock();

    public void enqueue(Object item) {
        lock.lock();
        try {
            queue.add(item);
        } finally {
            lock.unlock();
        }
    }

    public Object dequeue() {
        lock.lock();
        try {
            return queue.poll();
        } finally {
            lock.unlock();
        }
    }
}