getAsync(“key”)。get(timeout,sec)不等待,返回null

对我来说,这感觉就像你希望它等待一个值被放入地图,不是吗?

这并不意味着它将等待一个值变为可用,它只是为集群完全耗尽并且无法足够快地响应请求的情况提供了一个超时选项。

事实上,我认为没有好的方法可以实现您所期望的目标,但您可以使用本地EntryListeners,等待密钥并通过主题转发事件,如果这有意义的话。您可能还需要Promise类型的实现。

不确定是否与3.4.4有关,但3.5.1有效(来自REPL):

scala> import scala.concurrent._
import scala.concurrent._

scala> import ExecutionContext.Implicits.global
import ExecutionContext.Implicits.global

scala> val map = hz.getMap[String, Int]("map")
map: com.hazelcast.core.IMap[String,Int] = IMap{name='map'}

scala> map.set("one", 1)

scala> map.getAsync("one").get()
res4: Int = 1