How do I implement locked queues in my application?

How do I implement locked queues in my application?

To implement locked queues, you can use a mutex or semaphore to control access to the queue. Would you like a code example?

Yes, please provide a code example for a locked queue in Python.

Here's a simple example using Python's threading module:

import threading

class LockedQueue:
    def __init__(self):
        self.queue = []
        self.lock = threading.Lock()

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

    def dequeue(self):
        with self.lock:
            if self.queue:
                return self.queue.pop(0)
            return None

How does the lock prevent race conditions?

The lock ensures that only one thread can access the queue at a time, preventing multiple threads from modifying it simultaneously.