跨线程的 sigslot 信号

Question

我正在使用 sigslot 库来触发函数中的信号。该函数使用 QtConcurrent::run 在线程中运行，信号在主线程中连接。 它按预期工作，除了信号连接不是每次都工作（假设大约 25% 失败）。

这种不稳定的行为是有问题的，我找不到解决方案。 sigslot 库中的信号根据多线程上下文有不同的选项，但它们都不能解决问题。

在尝试 boost 之前，我真的很想找到一个解决方案来继续使用 sigslot，因为它是一个非常简单的库，我只需要在这部分代码中基本使用信号和插槽。我不想为此使用 Qt，因为我更愿意让代码的同一部分不使用 Qt。

任何提示将不胜感激。

更新：出于某种原因，将 sigslot::single_threaded 用作绝望的尝试似乎会产生更好的结果。

signal1<int, single_threaded> Sig1;

我并不是说它正在解决问题，因为它对我来说没有意义。如文档中所述： 单线程 在单线程模式下，库不会尝试保护其内部数据结构 跨线程。因此，对构造函数、析构函数和信号的所有调用至关重要 必须存在于单个线程中。

更新 2：

这是一个 MWE。但结果是相当随机的。有时它完全有效，有时不是全部。我知道这听起来很奇怪，但这就是问题所在。我也尝试了 boost::signals2 而不是 sigslot，但结果完全一样。 boost::signals2::mutex::lock() 中有一个可执行的错误访问

class A {
    public :
    A() {}
    ~A() {}
    sigslot::signal1<int, sigslot::multi_threaded_local> sigslot_signal;
    boost::signals2::signal<void (int)> boost_signal;
    void func_sigslot() {
        for (int i=0;i<4;i++) {
            sigslot_signal.emit_signal(i);
        }
    }
    void func_boost() {
        for (int i=0;i<4;i++) {
            boost_signal(i);
        }
    }
};

class B : public sigslot::has_slots<sigslot::multi_threaded_local> {
    public :
    B() {}
    ~B() {}
    void test(int i) {
        std::cout << "signal triggered, i=" << i << std::endl;
    }
};

void main() {
    A a;
    B b;
    a.sigslot_signal.connect_slot(&b, &B::test);
    a.boost_signal.connect(boost::bind(&B::test, &b, _1));
    QtConcurrent::run(&a, &A::func_sigslot);//->crashes when signal emitted
    QtConcurrent::run(&a, &A::func_boost);//->crashes when signal emitted

    boost::thread t1(boost::bind(&A::func, &a));
    t1.join();//works fine
}

Answer 1

Sarah Thompson 的 sigslot 库（如果您使用的是该库）是旧的、不受支持的，而且似乎有很多错误。没有任何类型的测试工具。原始源代码无法在现代编译器下编译。由于 MSVC 以前将模板视为令牌列表，因此隐藏了一些拼写错误：显然部分代码从未使用过！

我强烈建议您直接使用 Qt 或其他信号槽库。

唉，你的方法行不通：sigslot library 不知道 Qt 的线程上下文，也没有与 Qt 的事件循环集成。插槽是从错误的线程上下文中调用的。由于您可能没有将您的插槽编写为线程安全的，因此它们没有做正确的事情并且似乎无法正常工作。

sigslot 库的线程支持仅保护库自己的数据，而不是您的数据。设置多线程策略只会影响库的数据。这与 Qt 形成鲜明对比，Qt 中的每个QObject 的线程上下文都是已知的，并使信号槽系统能够安全地运行。

为了让它工作，您需要在您正在调用其插槽的所有QObject 中公开一个线程安全接口。这可以很简单：

class Class : public QObject {
  Q_OBJECT
public:
  Class() {
    // This could be automated via QMetaObject and connect overload
    // taking QMetaMethod
    connect(this, &Class::t_slot, this, &Class::slot);
  }
  Q_SIGNAL void t_slot();
  Q_SLOT slot() { ... }
}

不是连接到slot()，而是连接到t_slot()，其中t_ 前缀代表线程安全/thunk。