ListenableFuture to scala Future

Question

Jestem w trakcie pisania małego opakowania scala wokół biblioteki Java.

Biblioteka Java ma QueryExecutor obiektu poddawanie 2 metodami:

• wykonanie (hasła): Wynik
• asyncExecute (zapytanie) ListenableFuture [wynik]

ListenableFuture w tym kontekście ten z biblioteki guawy.

Chcę, aby moje opakowanie scala zwróciło wartość Future [Result] zamiast obiektu java, ale nie jestem pewien, jaki jest najlepszy sposób na jego implementację. Tu są 2 rozwiązania wymyśliłem:

future { 
    executor.execute(query) 
} 

i

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 

Zastanawiam się, która metoda jest najlepsza. Moją intuicją jest, że pierwsza, zwracając Przyszłość, będzie nadal blokować wątek, podczas gdy wywołanie wykonania czeka na odpowiedź, druga wygląda tak, jakby nie była blokowana. Wszelkie uwagi na temat zalet/wad każdej metody?

Answer 1

Druga opcja jest najlepsza, zachowuje wszystko asynchronicznie. ale ... można zrobić jeden lepszy i abstrakcyjne roztwór do wielokrotnego użytku wzoru:

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 
    }  
} 

Następnie można po prostu zadzwonić:

executor.asyncExecute(query).asScala