代码之家 › 专栏 › 技术社区 › Davide Icardi i3arnon

将IgniteCursor[T]/Iterable[T]转换为Future[Seq[T]]

iterable ignite future asynchronous scala

Davide Icardi i3arnon · 技术社区 · 6 年前

与 Scala Iterable[t] 到a Future[Seq[T]] ?

我想以非阻塞的方式读取光标。

val iterable = cursor.asScala
val result = iterable.toList

Future{
  result
}

但我认为这段代码是阻塞的,不是异步的。我是对的?

Iterable 到a Future[Seq] 有道理?

我的目标是在不阻塞调用线程或工作线程的情况下获得一个小的记录列表,因为我将接收许多并发调用。

可迭代的 实际上是一个 IgniteCursor 所以在内部我想它会执行一些网络/数据库操作。通常有异步执行这些操作的方法。例如,读取一个我可以使用的值 getAsync get
对于我刚刚拥有的光标 getAll 函数,所以我的想法是使用 可迭代的 以一种聪明的方式。
我的理解是,当使用异步方法时,线程不会被阻塞,但它们可以自由地执行其他任务,直到网络操作完成。我希望函数返回 Future / IgniteFuture
有没有一种方法可以在不阻塞线程的情况下获取所有记录?

最后我需要释放资源 close 功能。如果我写信 Future(cursor.asScala.toList) onComplete 的 未来

另一个简单的解决办法是写作 Future{cursor.getAll.asScala} 但是我认为在内部一个worker线程将被阻塞以等待所有记录。

更新2

2 回复 | 直到 6 年前

jwvh 6 年前

变形金刚 Iterable 到a Future[Seq] 有道理?

可迭代的 Seq 渴望并且会占用更多的记忆。从 可迭代的 顺序 你实际上是在说:“我不想看到任何数据,直到一切都准备好并加载到内存中。”

未来 您实际上是在说:“我稍后会回来(希望)所有数据元素都准备好并加载到内存中。”

Dima 6 年前

getAll ,那么你能用它来“聪明”吗?您有两种选择:要么调用内联,要么卸载到线程。

你能做的一件事就是把电话包起来 blocking :

Future { 
   blocking { 
      cursor.getAll.asScala
   }
}

封闭本身并不坏。只有当它导致线饥饿时才是坏的。

但是小心点。如果你的游标“很重”,而且你有很多游标并行运行,那么除了阻塞线程外,你会有问题。例如,您可能会耗尽内存,因为您将尝试一次性拟合所有结果。否则你会让IO饱和。

推荐文章

davidzxc574 · 将字符串缩放为字符

2 年前

yic_l · 什么是“!”在这个函数中是什么意思?

2 年前

Jelly · Scala:用于理解递归未来

2 年前

to.mane · Scala—如何使用接收对象作为参数的构造函数创建类

2 年前

bbgghh · 在scala中连接两个列表时如何处理不匹配的键

2 年前

OdiumPura · 使用JDBC(Sql server)查询tempview

2 年前

Iheb Mar · 卡夫卡制作人/消费者粉碎每一秒的API调用

2 年前

B. Bal · 在Scala中重用类成员

2 年前

RomanGoltsov · Scala、Cassandra、Quill、Need impl logget批处理模式

2 年前

S.Hashiba · 哪个名称空间是正确的,“com.typesafe.sbt”还是“com.github.sbt”?

2 年前