ListenableFuture tocala Gelecek

Question

Ben bir java kütüphanesi etrafında küçük bir scala sarıcı yazma sürecindeim.

• yürütmek (sorgu):

bu bağlamda ListenableFuture olan ListenableFuture [Sonuç]:

asyncExecute (sorgu) Sonuç

java kütüphanesi 2 yöntem açığa bir amacı QueryExecutor sahip guava kütüphanesinden biri.

Benim scala sarmalayıcımın java nesnesi yerine bir Gelecek [Sonuç] döndürmesini istiyorum, ancak bunu gerçekleştirmenin en iyi yolunun ne olduğundan emin değilim.

future { 
    executor.execute(query) 
} 

ve

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 

merak yöntem en iyisi am: İşte ile geldi 2 çözümleridir. Benim sezgim, birincisi, bir Gelecek'i geri verirken, yürütme çağrısı bir cevap beklerken, ikincisi gerçekten engellenmemesi gerektiği gibi görünüyorsa da, bir iş parçacığını hala engelleyecektir. Her yöntemin artıları/eksileri hakkında herhangi bir yorum var mı?

Answer 1

İkinci seçenek en iyisi, herşeyi eşzamansız tutar. ama ... sen yeniden kullanılabilir kalıbı içine bir iyi ve soyut bir çözüm yapabilirsiniz:

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

Daha sonra sadece çağırabilirsiniz:

executor.asyncExecute(query).asScala