c++ - RxCpp 大量调用复制构造函数

Question

我试图在我的程序中包含 RxCpp，我注意到，该框架调用了很多发射对象的复制构造函数。

#include <iostream>
#include <rxcpp/rx.hpp>

class Foo
{
public:
    Foo() = default;

    Foo(Foo const &other)
    {
        std::cout << "Copy constructor called" << std::endl;
    };

    Foo(Foo &&other) noexcept
    {
        std::cout << "Move constructor called" << std::endl;
    };
};

int main()
{
    Foo bar;
    rxcpp::sources::just(std::move(bar))
            .subscribe(
                    [](Foo const &baz)
                    {
                        std::cout << "Foo received" << std::endl;
                    }
            );

    return 0;
}

运行这个输出

Move constructor called
Copy constructor called
Move constructor called
Move constructor called
Move constructor called
Move constructor called
Move constructor called
Copy constructor called
Copy constructor called
Copy constructor called
Copy constructor called
Copy constructor called
Copy constructor called
Copy constructor called
Copy constructor called
Copy constructor called
Copy constructor called
Foo received

我首先在 subject 上注意到了这一点，我想用它发布一个在网络操作完成后在堆栈上创建的对象。在那种情况下，复制构造函数被(仅？)调用了 4 次，但中间没有任何运算符在起作用，并且主题只有一个订阅者。

我明白，调用复制构造函数是必要的，因为多个观察者可能正在监听并且他们不能共享移动的对象。我还希望可观察对象上的每个运算符(operator)都像另一个订阅者一样。

但是，我不明白为什么它在内部发生这么多，尤其是在这个例子中。这感觉就像我做错了什么。有什么方法可以优化这个吗？如果只有一个订阅者，为什么不使用移动构造函数也有充分的理由吗？

通常使用 std::shared_ptr 通过 observable 发射更大的对象以避免复制构造函数调用是个好主意吗？

Answer 1

是的，rxcpp 做了很多拷贝。负担在于可以廉价复制的值(value)。

欢迎 PR，但必须保留允许多次调用每个 subscribe() 的现有模型。

这意味着每次调用订阅都会创建一个订阅，并且必须为该订阅创建一个值的拷贝。

如果订阅是线程上的第一个订阅(如本例)，则订阅本身会执行额外的步骤。它使用当前线程调度程序来获取线程的所有权。这很可能会将发件人复制到计划的工作中。这是可以保存一些拷贝的情况。

just() 本身可能会使用指定的调度程序 arg 来安排对 on_next 的调用，在这种情况下，它默认为当前线程调度程序，并带有另一个值的拷贝。