How do I implement a queue in C++ for multithreading?

How do I implement a queue in C++ for multithreading?

You can use the Standard Template Library (STL) to implement a queue. The std::queue class is thread-safe when used with mutexes.

Can you show me a simple example of using std::queue with threads?

Sure! Here's a basic example:

#include <iostream>
#include <queue>
#include <thread>
#include <mutex>
#include <condition_variable>

std::queue<int> myQueue;
std::mutex mtx;
std::condition_variable cv;

void producer() {
    for (int i = 0; i < 10; ++i) {
        std::lock_guard<std::mutex> lock(mtx);
        myQueue.push(i);
        cv.notify_one();
    }
}

void consumer() {
    for (int i = 0; i < 10; ++i) {
        std::unique_lock<std::mutex> lock(mtx);
        cv.wait(lock, [] { return !myQueue.empty(); });
        int value = myQueue.front();
        myQueue.pop();
        std::cout << "Consumed: " << value << std::endl;
    }
}

int main() {
    std::thread prod(producer);
    std::thread cons(consumer);
    prod.join();
    cons.join();
    return 0;
}

This code creates a producer that adds items to the queue and a consumer that removes them.

What are the potential issues I should be aware of when using queues in multithreading?

Some potential issues include race conditions, deadlocks, and ensuring that the queue is properly synchronized to avoid data corruption.