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

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

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

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

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

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

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

解决方法

在聊天中讨论后，结论是 OP 唯一需要做的就是使用适当的 (compute) 在应用程序入口点中创建一个 ContextShift EC 然后将其传递给包含此方法的类。

// 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)

---

此 Scastie 展示了一种使用 Blocker 和 Typelevel 生态系统中常见但并不真正适合 OP 用例的其他技术的方法；无论如何，我发现它对未来可能遇到类似问题的读者很有用。