boost::io_service、线程和 std::set

Question

如果有比调试试图描述错误本身的多线程应用程序更困难的事情。

• 我有两个 boost::threads （应用程序和显示）。
• 两者都使用相同的 asio::io_service 来完成其工作。 显示线程有一个 window* 类型的 std::set ，它是我用来包装 winapi 窗口管理的类。
• 我使用自定义消息队列来通信这两个线程。
• 这些消息之一（终止）用于通知显示线程它不能再“发布”任何方法，并且它必须调用 thread_group.remove_thread 并删除自身。
• 线程有一个变量（状态）来标记线程的状态（运行、暂停、终止）。
• 如果它正在运行，它会“发布”它的 update() 方法，该方法会迭代 std::set 并在它包含的每个窗口* 中调用 update 方法。
• 如果它终止，它会清除 std::set，将自身从 thread_group 中删除，并且不再发布任何工作。

问题：有时，当尝试关闭应用程序时，线程的更新方法会在线程“终止”并且 std::set 被清除后运行。然后 update 方法尝试迭代 std::set 并发生 SIGSEGV。该应用程序每运行 10 次才会出现 1 次这种情况，我很难猜测出了什么问题。

我会尝试发布相关代码，如果需要更多我会尝试添加它。

int main(int argc, char **argv)
{
    boost::asio::io_service ios;
    boost::asio::strand     strand(ios);
    boost::thread_group     threads;
    owl::system::pump       pump;

    application app(&threads, &strand, &pump);
    owl::system::display display(&strand, &pump);

    ios.run();
    threads.join_all();

    return 0;
}
...
void display::on_terminate()
{
    close_all_windows();
}
...
void display::close_all_windows()
{
    windows.move_first();
    while (!windows.eof())
    {
        window* win = windows.value();
        win->destroy();
        delete win;
        windows.move_next();
    }
    windows.clear();
    check_no_window();
}
...
void display::on_update()
{
    if (windows.size())
    {
        windows.move_first();
        while (!windows.eof())
        {
            windows.value()->update();
            windows.move_next(); // Here happens the SIGSEGV
        }
    }
}

类显示继承了管理线程执行的类子系统。这是涉及执行 on_update() 的相关代码

void subsystem::do_update()
{
    message* msg;

    size_t message_count = messages.size();
    for (size_t i=0; i<message_count; i++)
    {
        msg = messages[i];
        process_message(msg);
        strand->dispatch(strand->wrap(boost::bind(&message::deallocate, msg)));
    }

    switch (state)
    {
        case running:
        {
            on_update();
        }
        break;
        case paused:
        {
            // Do not update. Just check the queue and sleep
            sleep(10);
        }
        break;
        case terminated:
        {
            do_terminate();
            return;
        }
        break;
    }
        strand->post(strand->wrap(boost::bind(&subsystem::check_for_messages, this)));
}

void subsystem::check_for_messages()
{
        messages.clear();
    pump->get_messages(this, messages);
    ios->post(boost::bind(&subsystem::do_update, this));
}

SIGSEGV 恰好在尝试递增 std::set 迭代器时发生。

Child process PID: 2272
Program received signal SIGSEGV, Segmentation fault.
In std::_Rb_tree_increment(std::_Rb_tree_node_base const*) ()
stl_tree.h:269