问题描述
我正在使用 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。