如何在Linux C++中實現線程的優(yōu)雅退出

在 Linux 中，使用 C++ 實現線程的優(yōu)雅退出可以通過以下方法：

1. 使用條件變量（Condition Variable）：

條件變量可以用于線程間的同步。當一個線程需要通知其他線程退出時，可以使用條件變量。這里是一個簡單的例子：

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

std::mutex mtx;
std::condition_variable cv;
bool exit_flag = false;

void worker() {
    std::unique_lock<std::mutex> lock(mtx);
    while (!exit_flag) {
        // 執(zhí)行任務
        std::cout << "Working...\n";

        // 等待一段時間
        cv.wait_for(lock, std::chrono::seconds(1));
    }
}

int main() {
    std::vector<std::thread> threads;
    for (int i = 0; i < 5; ++i) {
        threads.emplace_back(worker);
    }

    std::this_thread::sleep_for(std::chrono::seconds(3));
    {
        std::lock_guard<std::mutex> lock(mtx);
        exit_flag = true;
    }
    cv.notify_all();

    for (auto& t : threads) {
        t.join();
    }

    return 0;
}

2. 使用原子操作（Atomic Operations）：

原子操作可以確保在多線程環(huán)境下對共享數據的操作是線程安全的。這里是一個簡單的例子：

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

std::atomic<bool> exit_flag(false);

void worker() {
    while (!exit_flag) {
        // 執(zhí)行任務
        std::cout << "Working...\n";

        // 等待一段時間
        std::this_thread::sleep_for(std::chrono::seconds(1));
    }
}

int main() {
    std::vector<std::thread> threads;
    for (int i = 0; i < 5; ++i) {
        threads.emplace_back(worker);
    }

    std::this_thread::sleep_for(std::chrono::seconds(3));
    exit_flag = true;

    for (auto& t : threads) {
        t.join();
    }

    return 0;
}

在這兩個例子中，我們創(chuàng)建了一個名為 exit_flag 的共享變量，用于通知線程退出。當主線程需要通知所有工作線程退出時，它將 exit_flag 設置為 true。工作線程會檢查 exit_flag 的值，如果為 true，則退出循環(huán)并結束線程。