91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

C++引擎的多線程處理策略

c++
小樊
82
2024-09-04 09:32:59
欄目: 編程語言

在C++中,實現多線程處理主要依賴于C++11標準引入的<thread>

  1. 線程創建:使用std::thread類創建線程。例如:
#include<iostream>
#include<thread>

void myFunction() {
    std::cout << "This is a new thread."<< std::endl;
}

int main() {
    std::thread t(myFunction); // 創建一個新線程并運行myFunction
    t.join(); // 等待線程完成
    return 0;
}
  1. 線程同步:為了避免數據競爭和同步問題,可以使用互斥鎖(std::mutex)來保護共享數據。例如:
#include<iostream>
#include<thread>
#include <mutex>

std::mutex mtx; // 全局互斥鎖
int sharedData = 0;

void increment(int n) {
    for (int i = 0; i < n; ++i) {
        mtx.lock(); // 加鎖
        ++sharedData;
        mtx.unlock(); // 解鎖
    }
}

int main() {
    std::thread t1(increment, 100000);
    std::thread t2(increment, 100000);

    t1.join();
    t2.join();

    std::cout << "Shared data: "<< sharedData<< std::endl;
    return 0;
}
  1. 條件變量std::condition_variable允許線程等待某個條件成立。例如,生產者-消費者模型:
#include<iostream>
#include<thread>
#include <mutex>
#include<condition_variable>
#include<queue>

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

void producer() {
    for (int i = 0; i < 10; ++i) {
        std::unique_lock<std::mutex> lock(mtx);
        dataQueue.push(i);
        cv.notify_one(); // 通知消費者有新數據
        lock.unlock();
    }
}

void consumer() {
    while (true) {
        std::unique_lock<std::mutex> lock(mtx);
        cv.wait(lock, [] { return !dataQueue.empty(); }); // 等待有數據
        int data = dataQueue.front();
        dataQueue.pop();
        lock.unlock();

        if (data == -1) break; // 特殊值表示結束

        std::cout << "Consumed: "<< data<< std::endl;
    }
}

int main() {
    std::thread p(producer);
    std::thread c(consumer);

    p.join();

    {
        std::unique_lock<std::mutex> lock(mtx);
        dataQueue.push(-1); // 添加特殊值表示結束
        cv.notify_one();
    }

    c.join();
    return 0;
}
  1. 原子操作std::atomic提供了一種無鎖的方式來保證原子性操作。例如:
#include<iostream>
#include<thread>
#include<atomic>

std::atomic<int> sharedData(0);

void increment(int n) {
    for (int i = 0; i < n; ++i) {
        ++sharedData;
    }
}

int main() {
    std::thread t1(increment, 100000);
    std::thread t2(increment, 100000);

    t1.join();
    t2.join();

    std::cout << "Shared data: "<< sharedData<< std::endl;
    return 0;
}
  1. 線程池:為了避免頻繁創建和銷毀線程帶來的開銷,可以使用線程池來管理線程。C++標準庫沒有直接提供線程池,但可以使用第三方庫如boost.asio或自行實現一個簡單的線程池。

這些策略可以根據不同的場景和需求進行組合使用,以實現高效的多線程處理。請注意,正確地使用多線程需要仔細考慮線程安全、同步和數據競爭等問題,以避免出現錯誤和未定義行為。

0
扶余县| 水富县| 灌阳县| 关岭| 宜城市| 尚志市| 合肥市| 定安县| 江达县| 都安| 石渠县| 卫辉市| 横山县| 阳春市| 五峰| 忻州市| 冕宁县| 上林县| 瑞丽市| 搜索| 九台市| 泰顺县| 高邑县| 马关县| 佛冈县| 兰州市| 泸西县| 台山市| 成武县| 竹溪县| 西峡县| 旌德县| 宁国市| 石柱| 垦利县| 图们市| 新平| 新宾| 连山| 望奎县| 和田市|