How to check if a std::thread is still running? How to check if a std::thread is still running? multithreading multithreading

How to check if a std::thread is still running?


If you are willing to make use of C++11 std::async and std::future for running your tasks, then you can utilize the wait_for function of std::future to check if the thread is still running in a neat way like this:

#include <future>#include <thread>#include <chrono>#include <iostream>int main() {    using namespace std::chrono_literals;    /* Run some task on new thread. The launch policy std::launch::async       makes sure that the task is run asynchronously on a new thread. */    auto future = std::async(std::launch::async, [] {        std::this_thread::sleep_for(3s);        return 8;    });    // Use wait_for() with zero milliseconds to check thread status.    auto status = future.wait_for(0ms);    // Print status.    if (status == std::future_status::ready) {        std::cout << "Thread finished" << std::endl;    } else {        std::cout << "Thread still running" << std::endl;    }    auto result = future.get(); // Get result.}

If you must use std::thread then you can use std::promise to get a future object:

#include <future>#include <thread>#include <chrono>#include <iostream>int main() {    using namespace std::chrono_literals;    // Create a promise and get its future.    std::promise<bool> p;    auto future = p.get_future();    // Run some task on a new thread.    std::thread t([&p] {        std::this_thread::sleep_for(3s);        p.set_value(true); // Is done atomically.    });    // Get thread status using wait_for as before.    auto status = future.wait_for(0ms);    // Print status.    if (status == std::future_status::ready) {        std::cout << "Thread finished" << std::endl;    } else {        std::cout << "Thread still running" << std::endl;    }    t.join(); // Join thread.}

Both of these examples will output:

Thread still running

This is of course because the thread status is checked before the task is finished.

But then again, it might be simpler to just do it like others have already mentioned:

#include <thread>#include <atomic>#include <chrono>#include <iostream>int main() {    using namespace std::chrono_literals;    std::atomic<bool> done(false); // Use an atomic flag.    /* Run some task on a new thread.       Make sure to set the done flag to true when finished. */    std::thread t([&done] {        std::this_thread::sleep_for(3s);        done = true;    });    // Print status.    if (done) {        std::cout << "Thread finished" << std::endl;    } else {        std::cout << "Thread still running" << std::endl;    }    t.join(); // Join thread.}

Edit:

There's also the std::packaged_task for use with std::thread for a cleaner solution than using std::promise:

#include <future>#include <thread>#include <chrono>#include <iostream>int main() {    using namespace std::chrono_literals;    // Create a packaged_task using some task and get its future.    std::packaged_task<void()> task([] {        std::this_thread::sleep_for(3s);    });    auto future = task.get_future();    // Run task on new thread.    std::thread t(std::move(task));    // Get thread status using wait_for as before.    auto status = future.wait_for(0ms);    // Print status.    if (status == std::future_status::ready) {        // ...    }    t.join(); // Join thread.}


An easy solution is to have a boolean variable that the thread sets to true on regular intervals, and that is checked and set to false by the thread wanting to know the status. If the variable is false for to long then the thread is no longer considered active.

A more thread-safe way is to have a counter that is increased by the child thread, and the main thread compares the counter to a stored value and if the same after too long time then the child thread is considered not active.

Note however, there is no way in C++11 to actually kill or remove a thread that has hanged.

Edit How to check if a thread has cleanly exited or not: Basically the same technique as described in the first paragraph; Have a boolean variable initialized to false. The last thing the child thread does is set it to true. The main thread can then check that variable, and if true do a join on the child thread without much (if any) blocking.

Edit2 If the thread exits due to an exception, then have two thread "main" functions: The first one have a try-catch inside which it calls the second "real" main thread function. This first main function sets the "have_exited" variable. Something like this:

bool thread_done = false;void *thread_function(void *arg){    void *res = nullptr;    try    {        res = real_thread_function(arg);    }    catch (...)    {    }    thread_done = true;    return res;}


This simple mechanism you can use for detecting finishing of a thread without blocking in join method.

std::thread thread([&thread]() {    sleep(3);    thread.detach();});while(thread.joinable())    sleep(1);