可听未来到斯卡拉未来

Question

我正在围绕java库编写一个小的scala包装器。

Java库有一个对象QueryExecutor，它公开了2种方法：

• 执行（查询）：结果
• asyncExecute（查询）：ListenableFuture[结果]

本文中的ListenableFuture是来自guava图书馆的。

我希望我的scala包装器返回一个Future[Result]而不是java对象，但我不确定实现它的最佳方法是什么。以下是我想出的2解决方案：

future {
  executor.execute(query)
}

和

val p = promise[Result]
val guavaFuture = executor.asyncExecute(query)

Futures.addCallback(guavaFuture, new FutureCallback[Result] {
  def onFailure(t: Throwable) {
    p.failure(t)
  }

  def onSuccess(result: Result) {
    p.success(result)
  }
})

p.future

我想知道哪种方法是最好的。我的直觉是，第一个函数在返回一个未来值时，仍然会阻塞一个线程，而executehtml" target="_blank">调用等待响应，第二个函数看起来应该是真正无阻塞的。对每种方法的利弊有何评论？

Answer 1

另一个略短的解决方案：

implicit class ListenableFutureDecorator[T](val f: ListenableFuture[T]) extends AnyVal {
  def asScala(implicit e: Executor): Future[T] = {
    val p = Promise[T]()
    f.addListener(() => p.complete(Try(f.get())), e)
    p.future
  }
}

Answer 2

第二个选项是最好的，它使一切保持异步。但是…您可以做得更好，并将解决方案抽象为可重用模式：

implicit class RichListenableFuture[T](lf: ListenableFuture[T]) {
  def asScala: Future[T] = {
    val p = Promise[T]()
    Futures.addCallback(lf, new FutureCallback[T] {
      def onFailure(t: Throwable): Unit = p failure t
      def onSuccess(result: T): Unit    = p success result
    })
    p.future
  }    
}

然后，您可以简单地调用：

executor.asyncExecute(query).asScala