我有一个
Java Future对象,我想将其转换为Scala Future.看看j.u.c.Future API,除了isDone方法之外我没有什么可以使用的.这是isDone方法阻止吗？
目前这就是我的想法：
val p = Promise() if(javaFuture.isDone()) p.success(javaFuture.get)
有一个更好的方法吗？
解决方法
如何包装它(我假设这里有一个隐含的ExecutionContext)：
val scalaFuture = Future {
javaFuture.get
}
编辑：
一个简单的轮询策略可能如下所示(java.util.Future => F)：
def pollForResult[T](f: F[T]): Future[T] = Future {
Thread.sleep(500)
f
}.flatMap(f => if (f.isDone) Future { f.get } else pollForResult(f))
这将检查Java未来是否每500毫秒完成一次.显然,总阻塞时间与上面相同(向上舍入到最接近的500ms),但是这个解决方案将允许其他任务在ExecutionContext的同一个线程中交错.
