C++多線(xiàn)程在Linux下的線(xiàn)程安全集合操作

在Linux下，使用C++多線(xiàn)程時(shí)，線(xiàn)程安全集合操作是非常重要的

1. 使用互斥鎖（std::mutex）：

互斥鎖是最基本的同步原語(yǔ)，用于確保在同一時(shí)刻只有一個(gè)線(xiàn)程可以訪(fǎng)問(wèn)共享資源。C++標(biāo)準(zhǔn)庫(kù)提供了std::mutex類(lèi)，可以用來(lái)保護(hù)共享數(shù)據(jù)。

#include <iostream>
#include <vector>
#include <thread>
#include <mutex>

std::mutex mtx;
std::vector<int> shared_data;

void add_data(int value) {
    std::lock_guard<std::mutex> lock(mtx);
    shared_data.push_back(value);
}

int main() {
    std::thread t1(add_data, 1);
    std::thread t2(add_data, 2);

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

    for (int value : shared_data) {
        std::cout << value << " ";
    }

    return 0;
}

2. 使用原子操作（std::atomic）：

原子操作是一種特殊的操作，可以在不使用鎖的情況下保證線(xiàn)程安全。C++標(biāo)準(zhǔn)庫(kù)提供了std::atomic模板類(lèi)，可以用來(lái)保護(hù)簡(jiǎn)單的數(shù)據(jù)類(lèi)型。

#include <iostream>
#include <vector>
#include <thread>
#include <atomic>

std::vector<int> shared_data;
std::atomic<int> counter(0);

void add_data(int value) {
    int index = counter.fetch_add(1);
    shared_data[index] = value;
}

int main() {
    std::thread t1(add_data, 1);
    std::thread t2(add_data, 2);

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

    for (int value : shared_data) {
        std::cout << value << " ";
    }

    return 0;
}

3. 使用線(xiàn)程安全容器（std::concurrent_queue）：

C++標(biāo)準(zhǔn)庫(kù)提供了std::concurrent_queue模板類(lèi)，這是一個(gè)線(xiàn)程安全的隊(duì)列實(shí)現(xiàn)，可以在多線(xiàn)程環(huán)境下安全地使用。

#include <iostream>
#include <thread>
#include <concurrent_queue>

std::concurrent_queue<int> shared_queue;

void add_data(int value) {
    shared_queue.push(value);
}

void process_data() {
    int value;
    while (true) {
        if (shared_queue.try_pop(value)) {
            std::cout << value << " ";
        } else {
            std::this_thread::yield();
        }
    }
}

int main() {
    std::thread t1(add_data, 1);
    std::thread t2(add_data, 2);
    std::thread t3(process_data);

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

    return 0;
}

注意：std::concurrent_queue不支持迭代器，因此不能像其他容器那樣遍歷它。在使用時(shí)，需要根據(jù)具體需求選擇合適的線(xiàn)程安全集合操作。