从 std::thread 在主线程上执行回调函数

Question

我有一个在std::thread退出时执行回调函数的需求，回调函数应该在主线程上执行。

在创建线程时，我需要分离线程并且不能阻止线程完成的主循环执行。

我试过使用std::signal，但似乎没有在主线程上执行回调函数

#include <thread>
#include <csignal>
#include <iostream>


std::thread::id main_thread_id;

void func2()
{
    for(int i = 0; i < 10000000; i++)
    {
        // do something
    }
}

void func()
{
    for(int i = 0; i < 10; i++)
    {
        func2();
    }
    std::raise(SIGUSR1);
}

void callback(int signal)
{
    std::cout << "SIGNAL: " << signal << "      THREAD ID:" << 
    std::this_thread::get_id() << std::endl;
    bool b = std::this_thread::get_id() == main_thread_id;
    std::cout << "IS EXECUTED ON MAIN THREAD: " << b << std::endl;
}

int main()
{
    main_thread_id = std::this_thread::get_id();
    std::cout << "MAIN THREAD ID: " << std::this_thread::get_id() << std::endl;
    std::signal(SIGUSR1, callback);
    std::thread t1(func);
    t1.detach();

    for(int i = 0; i < 20; i++)
    {
        func2();
    }

    if(t1.joinable())
        t1.join();
}

我得到的结果是回调函数没有在主线程上执行。请建议我可以创建工作线程并在线程退出时在主线程上调用回调函数的方法。

感谢您的帮助

Answer 1

有几种方法可以做到这一点。

首先，您的主线程可能是运行一个 消息循环 。在这种情况下，您将一条带有有效载荷的消息排队，告诉主线程运行一些代码（通过消息的指针部分将代码传送到运行到主线程，或者将它在主线程检查的某个已知位置）。

第二种方法是 return 类似于 std::future<std::function<void()>> 对象的东西，主线程检查未来是否准备就绪。准备就绪后，它运行就是代码。

第三种方法是创建一个主线程等待的并发队列，并将您的消息（包含运行的代码）填充到该队列中。

这一切都需要主线程的积极配合。主线程不能被抢占并告诉运行没有它的合作不同的代码。

哪个最好取决于您没有选择在问题中提及的程序的功能。如果你是带有消息循环的图形GUI，就用消息循环。如果您是并行化某些工作的流式处理器，并且您不需要快速执行，但最终会希望阻塞并行工作，那么未来可能是最好的。如果你是一个消息传递通道类型的应用程序，一组队列可能是最好的。

从 std::thread 在主线程上执行回调函数

Execute callback function on main thread from std::thread

c++

multithreading

pthreads

boost-thread

c++11