4

我试图了解如何构建我的程序以在性能问题中使用 RX。
我的应用程序在 3D 世界中有一个对象向量。每个对象占据一个盒子，并有一个“命中”流，代表鼠标悬停在它上面。
我想到了如何构建的两个选项：

选项1

struct object_t
{
  string name_;
  box bounding_box_;
  observable<bool> hit_;
};

struct scene_t
{
  scene_t(observable<point> mouse) : hit_(hit(mouse)) 
  {
    add({"background", {/* ... */}, {}};
  }

  object_t& add(object_t o)
  {
    int object_index = objects_.size();
    o.hit_ = hit_
             .map([=](int index){ return index == object_index; })
             .distinct_until_changed();
    objects_.push_back(o);
    return objects_.back();
  }

  //! given a stream of mouse points,
  //! calculate on which object index(in objects_) the mouse is hover over. 
  //! 0 if its over the background. 
  observable<int> hit(observable<point> mouse);

  using objects_t = std::vector<object_t>;
  objects_t objects_; 
  observable<int> hit_
};

选项 2

struct object_t
{
  string name_;
  box bounding_box_;

  void signal_hit(boot is_hit) { hit_.get_observer().on_next(is_hit); }

  observable<bool> hit() const { return hit_.get_observable(); }

private:
  subject<bool> hit_;
};

struct scene_t
{
  scene_t(observable<point> mouse) : hit_(hit(mouse)) 
  {
    add({"background", {/* ... */}, {}};
    hit_
       .start_with(0)
       .buffer(2, 1) // take two hits together, the current and the previos
       .subscribe([this](std::vector<int> indices) {
          objects_[indices[1]].signal_hit(false); // we leave this one 
          objects_[indices[0]].signal_hit(true); // and entering this one
        });        
  }

  object_t& add(object_t o)
  {
    objects_.push_back(o);
    return objects_.back();
  }
  //! ... as above
};

现在的问题是如何将 hit 函数的结果链接到 object_t::hit 流。
我看到两种方法：

  1. 选项 1 功能齐全，但性能很差，因为对于每个鼠标点，所有对象流都需要计算它们的值。
  2. 选项 2. 功能不完整，因为我使用 subject 以命令的方式将值推送到正确的流。但性能非常好，因为只有正确的（两个）对象命中流才会触发。

注意： 实现在 rxcpp 中，但它适用于我们在其中包含 RX 的任何语言，或一般 FRP 范例，这就是为什么我标记 rxjs\rx.net\frp 等
提前感谢 :-)

4

1 回答 1

0

如果有一个可观察的源和 N 个订阅者，那么每次源发出时都必须至少进行 N 次计算。没有办法解决我能想到的。

于 2017-07-24T15:14:45.097 回答