How do I implement lock-based queues in my application?

How do I implement lock-based queues in my application?

To implement lock-based 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 in Python.

Here's a simple example 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 only one thread can access the queue at a time, preventing race conditions and ensuring thread safety.