Ruby Celluloid:附加到已经在进行的未来

Question

给定一个Celluloid Actor的实例，您可以使用future异步执行Actor方法，并在以后的某个时间点使用Future的value方法来获取Actor方法的结果(如有必要，使用阻塞)。

假设我在一个系统中有两个独立的组件，这两个组件都希望使用相同的Actor方法，这可能是一个非常昂贵的数据库查询。如果这两个组件分别调用actor.future.expensive_query，则查询将执行两次，每个调用者都将获得自己的单独Future对象以检索结果。此外，这两个查询将串行执行，而不是并发执行。相反，如果我希望第二次调用actor.future.expensive_query只是为了获得对第一个调用者创建的Future对象的引用，该怎么办？Celluloid能做到这一点吗？

Answer 1

是的，但也可以使用普通的Ruby，正如我将向您展示的那样。

例如，使用此自定义访问器：

def expensive_query!(*args)
  @expensive_query ||= future.expensive_query(*args)
  if @expensive_query.is_a? Celluloid::Future
    @expensive_query = @expensive_query.value
  end
  @expensive_query
end

请记住，如果您想再次运行查询，您将需要在外部某处执行此操作……否则，您将提取已经运行的查询的结果(存储在@expensive_query中)：

@expensive_query = nil

例如，也许在reset_expensive_query!中。