问题描述
我有一些猫的 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 (将#修改为@)