Opakowanie scala.concurrent.Future dla java.util.concurrent.Future

Question

Używam aplikacji Play Framework 2.1.1 z zewnętrzną biblioteką Java, która generuje wynik java.util.concurrent.Future. Używam scala future w przeciwieństwie do Akka, co uważam za słuszne w przypadku Play 2.1. Jak mogę zawinąć java.util.concurrent.Future do pliku scala.concurrent.Future, zachowując jednocześnie kodowanie nieblokujące?

def geConnection() : Connection = { 
    // blocking with get 
    connectionPool.getConnectionAsync().get(30000, TimeUnit.MILLISECONDS) 
} 

Powyższy kod zwraca połączenie, ale używa się tak, że staje się blokowanie

def getConnectionFuture() : Future[Connection] = { 
    future { 
    // how to remove blocking get and return a scala future? 
    connectionPool.getConnectionAsync().get(30000, TimeUnit.MILLISECONDS) 
    } 
} 

Idealnie chcę funkcję scala zwracającą połączenia jako przyszłego podobnego kodu powyżej, ale bez kodu blokowania przez get. Co jeszcze muszę dodać do funkcji, aby nie blokować.

Wszelkie wskaźniki byłyby świetne.

Answer 1

import java.util.concurrent.{Future => JFuture} 
import scala.concurrent.{Future => SFuture} 

Nie można zawinąć JFuture z SFuture bez blokowania, ponieważ nie jest zwrotna w SFuture (onComplete) i istnieje tylko blokuje get w JFuture.

Wszystko, co możesz zrobić, to utworzyć dodatkowy wątek i zablokować go za pomocą get, a następnie wypełnić Promise z wynikiem get.

val jfuture: JFuture[T] = ??? 
val promise = Promise[T]() 
new Thread(new Runnable { def run() { promise.complete(Try{ jfuture.get }) }}).start 
val future = promise.future 

Można sprawdzić isDone w nieskończonej pętli, ale nie sądzę, że jest lepszy niż blokowanie.

Answer 2

Future { 
    blocking { 
    jfuture.get 
    } 
} 

To pozwala ExecutionContext wiedzieć, że to co robisz ma zamiar blokować, dając mu szansę przeznaczyć więcej wątków. Jeśli nie dodasz blocking { }, możesz zabraknąć wątków.

Answer 3

Biblioteka scala-java8-compat udostępnia konwertery między kontraktami java8 i Scala Futures.

Konkretnie, można użyć FutureConverters.toScala(connectionPool.getConnectionAsync()) do konwersji java.util.concurrent.Future do scala.concurrent.Future

Answer 4

 import java.util.concurrent.{Future => JFuture} 
    import scala.concurrent.ExecutionContext.Implicits.global 
    import scala.concurrent.Future 
    import scala.util.Try 

    object JFuture2SFuture { 
     val jFuture: JFuture[Int] = ??? 
     val promise = Promise[Int]() 
     Future { promise.complete(Try(jFuture.get)) } //it is non blocking 
     val sFuture:Future[Int] = promise.future 

    }