ListenableFuture to scala Future

Question

Tôi đang trong quá trình viết một trình bao bọc scala nhỏ xung quanh một thư viện java.

Thư viện java có QueryExecutor đối tượng phơi bày 2 phương pháp:

• thực hiện (query): Kết quả
• asyncExecute (query): ListenableFuture [Kết quả]

ListenableFuture trong bối cảnh này là một từ thư viện ổi.

Tôi muốn trình bao bọc scala của tôi trả về một [Kết quả] tương lai thay vì đối tượng java, nhưng tôi không chắc cách tốt nhất để thực hiện điều đó là gì. Dưới đây là 2 giải pháp tôi đã đưa ra:

future { 
    executor.execute(query) 
} 

và

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 

tôi tự hỏi phương pháp nào là tốt nhất. Trực giác của tôi là cái đầu tiên, trong khi trả về một tương lai, sẽ vẫn chặn một luồng trong khi cuộc gọi thực hiện chờ phản hồi, cái thứ hai trông giống như nó thực sự không bị chặn. Bất kỳ bình luận về ưu/khuyết điểm của mỗi phương pháp?

Answer 1

Tùy chọn thứ hai là tốt nhất, nó giữ mọi thứ không đồng bộ. nhưng ... bạn có thể làm một tốt hơn và trừu tượng dung dịch vào một mô hình tái sử dụng:

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

Sau đó, bạn có thể chỉ cần gọi:

executor.asyncExecute(query).asScala