c++ - ASIO signal_set对多个IO线程不可靠，取决于代码顺序？

Question

编辑:我不再能够重现此问题。无需更改任何内容，无论现在的块顺序如何，signal_set都能可靠地工作。
我在程序中使用(独立)ASIO，并且为了在Ctrl + C上正常关闭，我使用了signal_set。当只有我的主线程调用io_context.run()时，一切正常。
然后，我添加了使用多个线程进行IO的选项。看起来像这样:

// begin block 1
asio::signal_set signals(io_context, SIGINT, SIGTERM);
signals.async_wait([&server, &signals] (const asio::error_code& ec, int signal) {
    std::cerr << "Received signal " << signal << ", exiting" << std::endl;
    server.shutdown();
    signals.clear();
});
// end block 1

// begin block 2
std::vector<std::thread> io_threads;
if (num_io_threads > 1) {
    for (int i = 1; i < num_io_threads; ++i) {
        io_threads.emplace_back([&io_context] () {io_context.run();});
    }
}
// end block 2

io_context.run();

for (auto& thread: io_threads) {
    thread.join();
}

但是，当我运行 num_io_threads > 1并按Ctrl + C时，程序突然停止而不是正常关闭。我认为可能是因为多余的线程“偷走”了信号，因为我没有屏蔽那些线程中的任何信号。
然后我有了一个预感，重新排序了代码，将块1移到了块2之下，并且可以肯定的是，正常关机可以再次可靠地工作。
我可以依靠这种行为吗？ 具体来说，是因为我在创建所有线程之后创建了 signal_set并调用了其 async_wait方法，还是可靠地触发了信号回调，还是因为其他原因？如果还有其他事情，可靠地触发信号回调的正确解决方案是什么？
我试图找到相关文档，但找不到任何文档。文档只说 programs must ensure that any signals registered using signal_set objects are unblocked in at least one thread.
一切都在带有g++ 4.8.5的CentOS 7上。

Answer 1

是的，您可以依靠它。
我个人对您看到按顺序报告区块的效果感到惊讶(＃1，＃2)。
我也不能重现它:
Live On Coliru

#include <boost/asio.hpp>
#include <iostream>

namespace boost::asio {
    using boost::system::error_code; // huh - maybe this is a non-boost Asio thing
}
namespace asio = boost::asio;

template <typename Executor> struct Server {
    Server(Executor ex)
            : s(make_strand(ex)),
              timer(s, std::chrono::high_resolution_clock::time_point::max())
    {
        timer.async_wait([](asio::error_code ec) {
            std::cout << "Server shutdown (" << ec.message() << ")" << std::endl;
        });
    }
    void shutdown() {
        post(s, [this] { timer.cancel(); });
    };

  private:
    asio::strand<Executor> s;
    asio::high_resolution_timer timer;
};

int main(int argc, char**) {
    std::vector<std::thread> io_threads;
    boost::asio::io_context io_context;
    const int num_io_threads = 30;

    Server server(io_context.get_executor());

    auto start_threads = [&io_threads, &io_context] { //"block #2"
        // "block 2"
        if (auto n = num_io_threads - (io_threads.size() + 1); n > 0) {
            std::cerr << "Starting " << n << " threads...\n";
            while (n--)
                io_threads.emplace_back([&io_context] { io_context.run(); });
        }
    };

    if (argc > 1)
        start_threads();

    std::cerr << "Starting signal_set...\n";
    // begin block 1
    asio::signal_set signals(io_context, SIGINT, SIGTERM);
    signals.async_wait(
        [&server, &signals](const asio::error_code& ec, int signal) {
            std::cerr << "Received signal " << ::strsignal(signal) << ", " << ec.message() << std::endl;
            if (!ec)
            {
                std::cerr << "Exiting" << std::endl;
                server.shutdown();
                signals.clear();
            }
        });
    // end block 1

    start_threads();

    io_context.run();

    for (auto& thread : io_threads) {
        thread.join();
    }
}

它以相等的“成功”运行两个排序:

./a.out        & sleep 1; kill -INT $!
./a.out order2 & sleep 1; kill -INT $!
Starting signal_set...
Starting 29 threads...
Received signal Interrupt, Success
Exiting
Server shutdown (Operation canceled)
bash: fork: retry: Resource temporarily unavailable
Starting 29 threads...
Starting signal_set...
bash: fork: retry: Resource temporarily unavailable
Received signal Interrupt, Success
Exiting
Server shutdown (Operation canceled)

一些想法:

signal_set不是线程安全的，因此请确保您不能同时访问它。

server.shutdown()也有同样的想法。在我的复制程序中，我将shutdown张贴在一条线上以避免种族。

我在信号处理程序

中添加了对 ec的检查

您真的应该在io线程中处理异常:https://stackoverflow.com/a/44500924/85371

甚至更简单，请考虑使用 asio::tread_pool ( Coliru )

概要
如果您可以使用上面的代码进行复制，则我怀疑信号集服务实现中是否存在(依赖于平台？)错误，值得报告/询问Asio开发人员。