फ्यूचर्स के बैच को पूरा करने के लिए प्रतीक्षा करते समय टाइमआउट?

Question

मेरे पास Futures का एक सेट है जो Callable s को Executor पर सबमिट करके बनाया गया है। छद्म कोड:

for all tasks 
    futures.add(executor.submit(new callable(task))) 

अब मैं सभी पूर्ण होने तक सभी एनयूटर इंतजार करना चाहता हूं। मुझे पता है कि मैं Future#get(timeout) पर कॉल कर सकता हूं लेकिन अगर मैं लूप में अपने सभी वायदा के लिए अनुक्रमिक रूप से कॉल करता हूं तो टाइम्सआउट जोड़ना शुरू हो जाता है। छद्म कोड:

for all futures 
    future.get(timeout) 

get परिणाम जब तक समय समाप्त के साथ ब्लॉक तैयार है। इसलिए, यदि पहली बार टाइमआउट से पहले पूरा हो जाता है और दूसरा टाइमआउट से पहले भी पूरा हो जाता है और इसलिए पूरे निष्पादन समय पर number of futures * timeouttimeout के बजाय सबसे अधिक है।

इसलिए, मैं एक ऐसी विधि की तलाश में हूं जो Future एस और एक टाइमआउट की सूची स्वीकार करता है, सभी समानांतर में चलता है और फिर भविष्य के परिणामों का संग्रह देता है। कोई विचार?

Answer 1

आप ExecutorService.invokeAll उपयोग कर सकते हैं:

पर क्रियान्वित दिया कार्यों, उनकी स्थिति धारण वायदा और परिणामों की एक सूची लौट रहा है जब सभी पूर्ण या समय समाप्त समाप्त हो रहा है, जो भी पहले हो। Future.isDone() लौटाई गई सूची के प्रत्येक तत्व के लिए सच है। वापसी पर, जो कार्य पूरा नहीं हुए हैं वे रद्द कर दिए गए हैं। ध्यान दें कि एक पूरा कार्य सामान्य रूप से या अपवाद फेंक कर समाप्त हो सकता है। इस प्रक्रिया के परिणाम प्रगति पर होने पर दिए गए संग्रह को संशोधित किया गया है, तो इस विधि के परिणाम अपरिभाषित हैं।

---

आप पहले से ही Future रों है कि आप पर नजर रखने की जरूरत है और invokeAll उपयोग नहीं कर सकते, तो आप बस समय समाप्ति खुद के माप सकते हैं। छद्म कोड:

long endTime = System.currentTimeMillis() + timeoutMS; 
for(f : futures) 
    f.get(Math.max(0, endTime - System.currentTimeMillis()), TimeUnit.MILLISECONDS); 

इस तरह आप ज्यादा से ज्यादा अवधि कि जब तक आप अपने समय समाप्ति तक पहुँचने के लिए छोड़ दिया है प्रत्येक भविष्य दे।