ListenableFuture to scala Future

Question

私は、Javaライブラリの周りに小さなスケーララッパーを書く過程にあります。

Javaライブラリは、2つの方法露光対象QueryExecutor有する：

• は（クエリ）を実行：
• asyncExecute（クエリ）の結果：ListenableFuture [結果]

ListenableFutureこのコンテキストにありますグアバライブラリのもの。

私はスカラーラッパーにJavaオブジェクトの代わりにFuture [Result]を返すようにしたいが、それを実装する最良の方法は何か分からない。私が最適な方法を疑問に思って

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 

：ここに私が思い付いた2つの溶液です。私の直感は、実行する呼び出しが応答を待つ間、未来を返す最初のスレッドはスレッドをブロックし、2番目のスレッドは実際にはブロックされないように見えるということです。各方法の賛否両論に対するコメント？

Answer 1

2番目のオプションは、すべてが非同期に保つことが最良です。しかし...あなたは、再利用可能なパターンに1つのより良いと抽象ソリューションを行うことができます。

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