将Java Future转换为Scala Future

发布时间：2020-12-15 03:06:37 所属栏目：Java 来源：网络整理

导读：我有一个 Java Future对象,我想将其转换为Scala Future.看看j.u.c.Future API,除了isDone方法之外我没有什么可以使用的.这是isDone方法阻止吗？目前这就是我的想法： val p = Promise()if(javaFuture.isDone()) p.success(javaFuture.get) 有一个更好的方法

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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!