我有一个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
的同一个线程中交错。
启动Scala 2.13
,标准库包括scala.jdk.FutureConverters
,它为Scala CompletableFuture/Future
隐式转换提供Java:
import scala.jdk.FutureConverters._
// val javaFuture = java.util.concurrent.CompletableFuture.completedFuture(12)
val scalaFuture = javaFuture.asScala
// scalaFuture: scala.concurrent.Future[Int] = Future(Success(12))
使用FutureConvertors(Scala中的内置util)将Java Future转换为Scala Future。
考虑一个将Java Future [Int]转换为Scala Future [Int]的示例::
import java.util.concurrent.CompletableFuture
import scala.compat.java8.FutureConverters
val javaFuture: java.util.concurrent.Future[Int] = ???
// Some method call which returns Java's Future[Int]
val scalaFuture: Future[Int] =
FutureConverters.toScala(CompletableFuture.supplyAsync(new Supplier[Int] {
override def get(): Int = javaFuture.get
}))
类似我们可以为任何自定义类型而不是Int。