在 C++ 中,priority_queue
并不是線程安全的。如果你想在多線程環境中使用它,你需要自己提供線程安全機制。
一種常見的方法是使用互斥鎖(mutex)來保護對優先隊列的訪問。你可以定義一個類來封裝優先隊列,并在訪問隊列時使用互斥鎖來保證線程安全。下面是一個簡單的例子:
#include <queue>
#include <mutex>
template <typename T>
class ThreadSafePriorityQueue {
public:
void push(const T& value) {
std::lock_guard<std::mutex> lock(mutex_);
queue_.push(value);
}
bool pop(T& value) {
std::lock_guard<std::mutex> lock(mutex_);
if (queue_.empty()) {
return false;
}
value = queue_.top();
queue_.pop();
return true;
}
private:
std::priority_queue<T> queue_;
std::mutex mutex_;
};
在這個例子中,我們定義了一個 ThreadSafePriorityQueue
類來封裝 std::priority_queue
。我們使用 std::lock_guard
來自動管理互斥鎖的生命周期,確保在訪問隊列時只有一個線程能夠持有鎖。
當然,這只是一個簡單的例子,你可能需要根據你的具體需求來設計更復雜的線程安全機制。另外,如果你的程序中有多個線程需要訪問優先隊列,你可能需要考慮使用更高級的同步原語,如條件變量等。