जावा 8 CompletableFuture पुनर्प्राप्ति के बराबर के साथ? उदाहरण के लिए असाधारण रूप से लेकिन CompletableFuture <U>

Question

मुझे असीमित परिणाम के साथ अपवाद को संभालने का एक स्पष्ट तरीका दिखाई नहीं देता है। उदाहरण के लिए, अगर मैं एक एसिंक ऑपरेशन पुनः प्रयास करना चाहता हूं। मैं इस तरह कुछ की उम्मीद करता हूं, हालांकि हैंडलएसिंक ऐसा नहीं करता जो आपको लगता है - यह कॉलबैक को अन्य थ्रेड पर असीमित रूप से चलाता है। यहां एक ComplestStage वापस लौटना सही नहीं है। दिन के खतरे का सवाल: तब अपवाद के रूप में अपवाद है तो क्या करना है।

CompletionStage<String> cf = askPong("cause error").handleAsync((x, t) -> { 
     if (t != null) { 
      return askPong("Ping"); 
     } else { 
      return x; 
     } 
    }); 

कहाँ askPong एक अभिनेता पूछते हैं:

public CompletionStage<String> askPong(String message){ 
    Future sFuture = ask(actorRef, message, 1000); 
    final CompletionStage<String> cs = toJava(sFuture); 
    return cs; 
} 

Answer 1

यह आपके लिए क्या देख रहे है?

askPong("cause error") 
     .handle((pong, ex) -> ex == null 
       ? CompletableFuture.completedFuture(pong) 
       : askPong("Ping") 
     ).thenCompose(x -> x); 

इसके अलावा, ...Async विधियों का उपयोग नहीं जब तक आप की आपूर्ति समारोह के शरीर के लिए इरादा एसिंक्रोनस रूप से निष्पादित किया जाना है। तो जब आप की तरह

.handleAsync((x, t) -> { 
    if (t != null) { 
     return askPong("Ping"); 
    } else { 
     return x; 
    }) 

कुछ करना आप if-then-else के लिए पूछ रहे हैं एक अलग थ्रेड में चलाने के लिए। चूंकि askPongCompletableFuture देता है, इसलिए संभवतः इसे असीमित रूप से चलाने का कोई कारण नहीं है।

Answer 2

स्कैला की वसूली करने के उचित तरीके को जानने का प्रयास करने में बहुत निराशा के बाद जावा 8 में, मैंने अपना खुद का लेखन समाप्त कर दिया। मैं अब भी अगर यह सबसे अच्छा तरीका है पता नहीं है, लेकिन मुझे लगता है जैसे कुछ बनाया:

public RecoveryChainAsync<T> recoverWith(Function<Throwable, 
             CompletableFuture<T>> fn); 

recoverWith के लिए कई बार कॉल के साथ, मैं वसूली श्रृंखला के अंदर कार्यों को कतार और वसूली के साथ अपने आप को प्रवाह को लागू "संभाल "। RecoveryChainAsync.getCompletableFuture() फिर पूरी श्रृंखला के लिए एक प्रतिनिधि CompletableFuture देता है। उम्मीद है की यह मदद करेगा।