Stream.parallel() एक नया धागा का उपयोग करता है?

Question

तो, मैं जावा 8. मैं एक धारा है कि एक अलग थ्रेड (सिर्फ शैक्षिक उद्देश्यों के लिए) पर चला सकते हैं

String oracle = "http://www.oracle.com"; 
URL url = new URL(oracle); 
BufferedReader in = new BufferedReader(new InputStreamReader(url.openStream())); 
in.lines().parallel().forEach(System.out::println); 
System.out.print("CLOSING THE INPUT STREAM!, shouldnt this crash?"); 
in.close(); 

बनाने के लिए कोशिश कर रहा हूँ में शुरू की गई स्ट्रीम एपीआई के आसपास मेरे सिर प्राप्त करने के लिए कोशिश कर रहा हूँ नतीजा यह नहीं है कि मैं क्या उम्मीद करूंगा .. (मैं एक दुर्घटना की उम्मीद कर रहा था, क्योंकि मैंने इनपुट स्ट्रीम बंद कर दिया था जबकि अन्य धागा इसे पढ़ रहा था)। .parallel() विधि कॉल पर ध्यान दें। इसके बजाए कोड किसी अनुक्रमिक तरीके से निष्पादित नहीं होता है, जिसमें कोई समस्या नहीं है।

उत्पादन:

<script language="JavaScript" src="http://www.oracleimg.com/us/assets/metrics/ora_ocom_hp.js"></script> 
<!-- End SiteCatalyst code --> 

      <!-- SS_END_SNIPPET(fragment6,1)--> 
<!-- SS_BEGIN_SNIPPET(fragment7,ui)-->   <!-- SS_END_SNIPPET(fragment7,ui)--> 
</html> 
CLOSING THE INPUT STREAM!, shouldnt this crash? 

किसी को भी पता है क्या हो रहा है? मेरा कोड क्यों नहीं क्रैश हो रहा है?

Answer 1

समानांतर धारा वास्तव में एकाधिक धागे के लिए लाइनों को पढ़ने के काम को विभाजित करने का प्रयास करेगी। लेकिन आमंत्रण स्वयं अवरुद्ध हो रहा है, यानी कथन तब तक प्रतीक्षा करता है जब तक कि सभी धागे अगले कथन (जहां आप इनपुट स्ट्रीम बंद करते हैं) पर आगे बढ़ने के लिए समाप्त हो जाते हैं। नोट करने के लिए

एक बात है कि forEach गारंटी नहीं देता कि समानांतर कार्यों धारा तत्वों की एक ही क्रम में निष्पादित, इसलिए इस मामले में मुद्रित लाइनों मूल वेब पेज के साथ एक ही क्रम में नहीं हो सकता है (https://docs.oracle.com/javase/8/docs/api/java/util/stream/Stream.html#forEach-java.util.function.Consumer- देखना है)।

Answer 2

यदि आप पृष्ठभूमि में चीजों को तुरंत पूरा करने के बिना अवरुद्ध करना चाहते हैं तो आप java.util.concurrent.CompletableFuture.runAsync(Runnable) और संबंधित विधियों का उपयोग कर सकते हैं। यह एक CompletableFuture देता है जिसे आवश्यक होने पर बाद में जोड़ा जा सकता है।

Answer 3

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

हालांकि एक विशेष मामला है: यदि समानांतर स्ट्रीम ऑपरेशन अपवाद फेंकता है, तो मुख्य थ्रेड में आपकी स्ट्रीम प्रसंस्करण समाप्त होती है (असाधारण रूप से), लेकिन अन्य पृष्ठभूमि धागे अभी भी कुछ इनपुट हिस्सों को संसाधित करना जारी रख सकते हैं। आप इस जाँच निम्नलिखित कोड का उपयोग कर सकते हैं:

// Create list of Strings "0", "1", "2", ..., "99" 
List<String> list = IntStream.range(0, 100).mapToObj(String::valueOf) 
          .collect(Collectors.toCollection(ArrayList::new)); 
// replace one with non-numeric 
list.set(1, "foo"); 

// Convert every string to number and print it 
try { 
    list.parallelStream().mapToInt(Integer::parseInt).forEach(System.out::println); 
} catch (NumberFormatException e) { 
    // well some non-number encountered 
} 
System.out.println("Exited"); 

इस कोड को आप कभी कभी देख सकते हैं कि कुछ संख्या "Exited" संदेश के बाद मुद्रित कर रहे हैं चल रहा है।