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

问题描述

我有一些猫的 IO 操作,其中包括 Future。简化:

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

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

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

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

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)