在 Cats-Effects 中使用“unsafeRunSync()”可以吗？

如何解决在 Cats-Effects 中使用“unsafeRunSync()”可以吗？

我正在使用 Doobie 和 in the examples that I found，它使用 unsafeRunSync，例如：

sql"select name from country"
  .query[String]    // Query0[String]
  .to[List]         // ConnectionIO[List[String]]
  .transact(xa)     // IO[List[String]]
  .unsafeRunSync    // List[String]
  .take(5)          // List[String]
  .foreach(println)

在幕后，此功能实现如下：

final def unsafeRunSync(): A = unsafeRunTimed(Duration.Inf).get

In the docs，我发现“请注意，此函数用于测试；它不应出现在您的主线生产代码中！”。我想知道在生产中使用 unsafeRunSync 是否可以在引擎盖下使用此功能？

此外，如果不使用 unsafeRunTimed，我该如何设置执行超时？

解决方法

好吧，这取决于您所说的“OK”究竟是什么意思。我不知道任何限制使用 unsafeRunSync 方法的法律。我也不认为任何主要的宗教都认为这是一种罪恶（尽管一些次要的宗教肯定会）。

也就是说，调用 unsafeRunSync 不是引用透明的，并且具有随之而来的所有缺点。也就是说，等式推理不在窗外。如果在任何时候涉及异步处理，它也会阻塞调用线程（并且在 ScalaJS 中它在这种情况下根本不起作用）。对我来说，这些是尽可能避免在生产代码中使用它的充分理由。也就是说，有些情况是不可能的。例如，您有时需要实现期望执行副作用的接口，例如 java.io.OutputStream。在那种情况下你无能为力，那些签名就是它们的样子。

然而，没有必要调用 unsafeRunTimed 来执行具有超时的操作。只需使用 race method 和 Timer。