How can I implement a thread-safe queue in Python?

How can I implement a thread-safe queue in Python?

You can use the queue module in Python, which provides a Queue class that is thread-safe. Would you like a code example?

Yes, please provide a code example.

Here's a simple example:

import queue
import threading

# Create a thread-safe queue
q = queue.Queue()

# Function to add items to the queue
def producer():
    for i in range(5):
        q.put(i)
        print(f'Produced {i}')

# Function to remove items from the queue
def consumer():
    while True:
        item = q.get()
        if item is None:
            break
        print(f'Consumed {item}')

# Start producer and consumer threads
prod_thread = threading.Thread(target=producer)
cons_thread = threading.Thread(target=consumer)

prod_thread.start()
cons_thread.start()

prod_thread.join()
q.put(None)  # Signal the consumer to exit
cons_thread.join()

What happens if I don't use a thread-safe queue?

If you don't use a thread-safe queue, you may encounter race conditions, leading to data corruption or unexpected behavior when multiple threads access the queue simultaneously.