运行future后回到IO纤程/线程

大佬教程收集整理的这篇文章主要介绍了运行future后回到IO纤程/线程，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决运行future后回到IO纤程/线程？

我有一些猫的 IO 操作，其中包括 Future。简化：@H_772_3@

IO(getValue())
  .flatMap(v => IO.fromFuture(IO(blockingProcessvalue(v)))(myBlockingPoolContextShift))
  .map(moreProcessing)

所以我在 IO 中有一些值，然后我需要使用返回 Future 的库进行一些阻塞操作，然后我需要对从 Future @H_772_3@

Future 在专用线程池上运行 - 到目前为止一切顺利。问题是在 Future 完成之后。 @H_989_5@moreProcessing 在运行 Future 的同一线程上运行。@H_772_3@

有没有办法回到 getValue() 正在运行的线程？@H_772_3@

解决方法

// Entry point

val computeEC = ???
val cs = IO.contextShift(computeEC)
val myClass = new MyClass(cs,...)

// Inside the method on MyClass
IO(getValue())
  .flatMap(v => IO.fromFuture(IO(blockingProcessvalue(v)))(myBlockingPoolContextShift))
  .flatTap(_ => cs.shift)
  .map(moreProcessing)

大佬总结

以上是大佬教程为你收集整理的运行future后回到IO纤程/线程全部内容，希望文章能够帮你解决运行future后回到IO纤程/线程所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。