फ्यूचर्स

Question

की सूची पर स्ट्रीम करने का सबसे प्रभावी तरीका मैं वस्तुओं की सूची पर स्ट्रीमिंग करके एसिंक क्लाइंट विधि को कॉल कर रहा हूं। विधि भविष्य लौटाता है।

कॉल के बाद लौटाए गए फ़्यूचर्स की सूची में पुन: प्रयास करने का सबसे अच्छा तरीका क्या है (ताकि उन भविष्य को संसाधित करने के लिए जो पहले आता है)?

नोट: एसिंक क्लाइंट केवल भविष्य को पूरा करने वाला भविष्य नहीं देता है।

के बाद कोड है:

List<Future<Object>> listOfFuture = objectsToProcess.parallelStream() 
    .map((object) -> { 
     /* calling an async client returning a Future<Object> */ }) 
    .collect(Collectors.toList()); 

Answer 1

List<Future<Object>> की इस सूची के बाद, मैं इसे एक कस्टम पूल के लिए प्रस्तुत होता है, बजाय डिफ़ॉल्ट स्ट्रीम समानांतर प्रसंस्करण का उपयोग करने का।

ऐसा इसलिए है क्योंकि स्ट्रीम एपीआई समानांतर प्रसंस्करण के लिए एक सामान्य पूल का उपयोग करता है और आप उन फ्यूचर्स पर get पर कॉल करेंगे (यदि यह प्रसंस्करण के लिए महत्वपूर्ण समय लेता है) - आप अन्य सभी स्ट्रीम ऑपरेशंस को अवरुद्ध करेंगे जो आपके आवेदन के भीतर समानांतर संचालन का उपयोग करते हैं यह एक किया जाता है।

यह होगा इस तरह एक सा:

forJoinPool.submit(() -> list.stream().parallel().map(future -> future.get()).collect(Collectors.toList())).get(); 

मैं की तरह एक कस्टम पूल के साथ जाना होगा दिखाया here