如何在 C 中有效地检查正在运行的 std::thread 的状态？

检查正在运行的 std::thread 的状态

在 C 中，std::thread 是一种用于实现并发的类。确定 std::thread 是否仍在运行可能具有挑战性，特别是在平台独立性至关重要的情况下。

最初，std::thread 缺少 timed_join() 方法，而 joinable() 并不适用于这个目的。提出了另一种解决方案，即利用 std::lock_guard 锁定线程内的互斥体，然后使用 try_lock() 方法评估它是否仍处于锁定状态，指示线程的运行状态。然而，这种策略被认为过于复杂。

检查线程状态的优雅解决方案

要获得更简洁的方法，请考虑利用 std::async 和 std::future。 std::async 在单独的线程上启用异步任务，而 std::future 允许检索操作的结果。 std::future 的 wait_for 函数可以与零毫秒超时一起使用，以有效地检查线程是否仍在运行：

#include <future>
#include <thread>
#include <chrono>
#include <iostream>

int main() {
    // Create an asynchronous task on a new thread using std::async.
    auto future = std::async(std::launch::async, [] {
        std::this_thread::sleep_for(3s);
        return 8;
    });

    // Check thread status using wait_for() with zero milliseconds.
    auto status = future.wait_for(0ms);

    // Print status according to the wait_for() result.
    if (status == std::future_status::ready) {
        std::cout << "Thread finished" << std::endl;
    } else {
        std::cout << "Thread still running" << std::endl;
    }

    auto result = future.get(); // Retrieve result.
}

或者，可以使用 std::promise 从中获取 future 对象a std::thread:

#include <future>
#include <thread>
#include <chrono>
#include <iostream>

int main() {
    // Create a promise and its associated future.
    std::promise<bool> p;
    auto future = p.get_future();

    // Run a task on a new thread using std::thread.
    std::thread t([&amp;p] {
        std::this_thread::sleep_for(3s);
        p.set_value(true); // Set the promise value atomically.
    });

    // Check thread status using wait_for() as previous example.
    auto status = future.wait_for(0ms);

    // Print status according to the wait_for() result.
    if (status == std::future_status::ready) {
        std::cout << "Thread finished" << std::endl;
    } else {
        std::cout << "Thread still running" << std::endl;
    }

    t.join(); // Join the thread.
}

两个示例最初都会显示“线程仍在运行”，因为在线程完成之前检查了状态。然而，一个更简单的解决方案是使用原子布尔标志：

#include <thread>
#include <atomic>
#include <chrono>
#include <iostream>

int main() {
    // Use an atomic boolean flag for thread status tracking.
    std::atomic<bool> done(false);

    // Run a task on a new thread that sets `done` to true when finished.
    std::thread t([&amp;done] {
        std::this_thread::sleep_for(3s);
        done = true;
    });

    // Check thread status using atomic flag.
    if (done) {
        std::cout << "Thread finished" << std::endl;
    } else {
        std::cout << "Thread still running" << std::endl;
    }

    t.join(); // Join the thread.
}

以上是如何在 C 中有效地检查正在运行的 std::thread 的状态？的详细内容。更多信息请关注PHP中文网其他相关文章！