亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

C++循環隊列的多線程應用案例

c++
小樊
93
2024-07-14 10:24:27
欄目: 編程語言

循環隊列在多線程應用中經常用于實現生產者消費者模型。下面是一個簡單的C++多線程應用案例,利用循環隊列實現生產者消費者模型:

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

const int QUEUE_SIZE = 10;

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

void producer() {
    for (int i = 0; i < 100; ++i) {
        std::unique_lock<std::mutex> lock(mtx);
        cv.wait(lock, []{ return q.size() < QUEUE_SIZE; });
        q.push(i);
        lock.unlock();
        cv.notify_all();
    }
}

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

int main() {
    std::thread prod_thread(producer);
    std::thread cons_thread(consumer);

    prod_thread.join();
    cons_thread.join();

    return 0;
}

在這個案例中,我們使用一個循環隊列q來存儲生產者產生的數據,隊列的最大容量為QUEUE_SIZE。生產者線程不斷向隊列中添加數據,如果隊列已滿,則等待消費者線程消費數據;消費者線程不斷從隊列中取出數據進行消費,如果隊列為空,則等待生產者線程生產數據。

通過使用互斥量mtx和條件變量cv,我們實現了線程間的同步和通信。生產者線程在生產數據時會獲取互斥量,然后判斷隊列是否已滿,如果已滿則等待消費者線程通知;消費者線程在消費數據時會獲取互斥量,然后判斷隊列是否為空,如果為空則等待生產者線程通知。

0
岫岩| 静安区| 紫金县| 波密县| 浦北县| 临沭县| 民和| 宝兴县| 宁安市| 乌什县| 三门县| 梓潼县| 大同县| 平邑县| 罗定市| 师宗县| 右玉县| 包头市| 侯马市| 五常市| 嘉义县| 子长县| 衡南县| 乳山市| 苏尼特左旗| 元谋县| 肥西县| 墨江| 泸溪县| 浙江省| 汉沽区| 武胜县| 土默特右旗| 新乐市| 江永县| 五台县| 涪陵区| 万荣县| 六安市| 佛冈县| 横山县|