【问题标题】:Ruby Celluloid: attach to already in progress Future红宝石赛璐珞:附加到已经在进行中的未来
【发布时间】:2015-01-05 12:06:31
【问题描述】:

给定一个赛璐珞 Actor 的实例,您可以使用 future 异步执行 Actor 方法,并在稍后的某个时间点使用 Future 的 value 方法获取 Actor 方法的结果(必要时阻塞) .

假设我在一个系统中有两个独立的组件,它们都想使用相同的 Actor 方法,可能是非常昂贵的数据库查询。如果这两个组件单独调用actor.future.expensive_query,则查询将被执行两次,每个调用者将获取自己单独的 Future 对象以检索结果。此外,这两个查询将连续执行,而不是同时执行。相反,如果我想对actor.future.expensive_query 进行第二次调用以获取对第一个调用者创建的 Future 对象的引用,该怎么办?赛璐珞可以做到这一点吗?

【问题讨论】:

    标签: ruby concurrency actor celluloid


    【解决方案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! 中。

    【讨论】:

      猜你喜欢
      • 2012-08-30
      • 2016-08-07
      • 1970-01-01
      • 2015-12-06
      • 2012-12-02
      • 1970-01-01
      • 1970-01-01
      • 2013-06-04
      • 1970-01-01
      相关资源
      最近更新 更多