C++ 如何从线程生成函数捕获 Boost 中线程抛出的异常

Question

我有一个 C++ 应用程序，我在其中使用 Boost 线程来提供并发性。基本示例如下:

processingThreadGroup->create_thread(boost::bind(process, clientSideSocket, this));

这里processingThreadGroup是boost中线程池的共享指针，process是我需要调用的函数。 clientSideSocket 和 this 是应该传递给流程函数的参数。

在流程函数中，如果检测到错误，我会抛出一个自定义异常。进程函数将数据发送到远程服务器。所以我的问题是，如何将此错误传播到调用堆栈？我想在清理后关闭系统。尝试了以下操作:

try {
    processingThreadGroup->create_thread(boost::bind(process, clientSideSocket, this));
} catch (CustomException& exception) {
    //code to handle the error
}

但是没有用。关于如何正确执行此操作的任何想法？

谢谢!

Answer 1

要传播返回值和异常，您应该使用future。这是一个简单的方法:

// R is the return type of process, may be void if you don't care about it
boost::packaged_task< R > task( boost::bind(process, clientSideSocket, this) );
boost::unique_future< R > future( task.get_future() );

processingThreadGroup->create_thread(task);

future.get();

这有许多您必须牢记的问题。首先，task 的生命周期必须延长 process 的异步执行。其次，get() 将阻塞直到 task 完成，如果它成功结束则返回它的值，或者如果抛出异常则传播异常。您可以使用各种函数来检查future 的状态，例如has_value()、has_exception()、is_ready( )。