【问题标题】: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! 中。