中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

C++ queue多線程操作的方法是什么

c++
小億
123
2023-11-08 19:09:06
欄目: 編程語言

在C++中,可以使用互斥鎖(mutex)來實現多線程環境下對queue的操作。

  1. 創建一個互斥鎖變量:std::mutex mtx;
  2. 使用互斥鎖保護對queue的操作,在需要對queue進行操作的地方加鎖和解鎖:
// 加鎖
std::lock_guard<std::mutex> lock(mtx);

// 對queue進行操作,比如push、pop等

// 解鎖
  1. 在多個線程中使用互斥鎖來保護對queue的操作,以防止競爭條件(race condition)的發生。

以下是一個使用互斥鎖實現多線程操作queue的示例代碼:

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

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

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

void consumer() {
    for (int i = 0; i < 10; ++i) {
        std::lock_guard<std::mutex> lock(mtx);
        if (!myQueue.empty()) {
            int value = myQueue.front();
            myQueue.pop();
            std::cout << "Consumer: " << value << std::endl;
        }
    }
}

int main() {
    std::thread producerThread(producer);
    std::thread consumerThread(consumer);

    producerThread.join();
    consumerThread.join();

    return 0;
}

在上述代碼中,producer線程向queue中推送數據,而consumer線程從queue中取出數據。互斥鎖(mtx)用來保護對queue的push和pop操作,以避免競爭條件的發生。

0
建宁县| 礼泉县| 从江县| 闽侯县| 宣恩县| 韶山市| 金沙县| 白朗县| 崇阳县| 调兵山市| 宁陕县| 呈贡县| 莒南县| 乐亭县| 民勤县| 修武县| 凤翔县| 绥中县| 大埔县| 绵阳市| 靖州| 江阴市| 泌阳县| 寿光市| 崇文区| 旌德县| 乐安县| 印江| 潼关县| 蒲江县| 平昌县| 九龙县| 长沙县| 青田县| 房山区| 沿河| 富民县| 招远市| 峨山| 浏阳市| 黔南|