सुस्त भविष्य के लिए भविष्य

Question

मैं जावा पुस्तकालय के चारों ओर एक छोटा सा स्काला रैपर लिखने की प्रक्रिया में हूं।

• अमल (क्वेरी): परिणाम
• asyncExecute (क्वेरी): ListenableFuture [परिणाम]

इस संदर्भ में ListenableFuture है

जावा पुस्तकालय एक वस्तु QueryExecutor 2 तरीकों को उजागर किया गया है अमरूद पुस्तकालय से एक।

मैं चाहता हूं कि मेरा स्कैला रैपर जावा ऑब्जेक्ट के बजाय भविष्य [परिणाम] लौटाए, लेकिन मुझे यकीन नहीं है कि इसे लागू करने का सबसे अच्छा तरीका क्या है।

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 समाधान मैं के साथ आया है। मेरा अंतर्ज्ञान यह है कि पहला, एक भविष्य लौटने पर, अभी भी एक थ्रेड को अवरुद्ध कर देगा, जबकि कॉल करने के लिए कॉल प्रतिक्रिया के लिए इंतजार कर रहा है, दूसरा ऐसा लगता है कि यह वास्तव में गैर अवरोध होना चाहिए। प्रत्येक विधि के पेशेवरों/विपक्ष पर कोई टिप्पणी?

Answer 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