如何在Linux C++中实现线程的优雅退出

在 Linux 中，使用 C++ 实现线程的优雅退出可以通过以下方法：

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) {
        // 执行任务
        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）：

原子操作可以确保在多线程环境下对共享数据的操作是线程安全的。这里是一个简单的例子：

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

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

void worker() {
    while (!exit_flag) {
        // 执行任务
        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;
}

在这两个例子中，我们创建了一个名为 exit_flag 的共享变量，用于通知线程退出。当主线程需要通知所有工作线程退出时，它将 exit_flag 设置为 true。工作线程会检查 exit_flag 的值，如果为 true，则退出循环并结束线程。