将Java Future转换为Scala Future

我有一个 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的同一个线程中交错.