How do I implement lock-based queues in code?

How do I implement lock-based queues in code?

To implement lock-based queues, you can use a mutex to ensure that only one thread accesses the queue at a time. Would you like a code example?

Yes, please provide a code example in Python.

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

import threading
from queue import Queue

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

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

    def dequeue(self):
        with self.lock:
            if not self.queue.empty():
                return self.queue.get()
            return None

How does the lock mechanism work in this example?

The lock ensures that when one thread is adding or removing an item from the queue, no other thread can access it, preventing race conditions.