streams अंदर से कैसे काम करते हैं, और आप parallel stream कब इस्तेमाल करेंगे?

stream lazy intermediate operations की एक pipeline बनाता है जो terminal operation चलने तक कुछ नहीं करती, और फिर elements एक ही पास में बहते हैं, इसीलिए map से पहले filter रखना मायने रखता है। Parallel streams source को साझा common ForkJoinPool पर बांट देते हैं। इन्हें सिर्फ बड़े, आसानी से बंटने वाले, CPU bound काम के लिए इस्तेमाल करें जिसमें कोई साझा mutable state न हो, और blocking I/O के लिए कभी नहीं, क्योंकि तब आप वह pool बांध देंगे जिसे पूरी application साझा करती है।

Intermediate operations सिर्फ pipeline बनाते हैं; तब तक कुछ नहीं होता जब तक कोई terminal operation elements को खींच न ले, और हर element पूरी चेन से गुजरता है, बजाय इसके कि हर operation के लिए collection एक बार घूमे। इसीलिए क्रम मायने रखता है, जल्दी filter करने से काम कम होता है, और इसीलिए findFirst जैसे short circuiting operations पूरे source को जल्दी रोक सकते हैं। Parallel streams को लेकर मैं सतर्क रहता हूं। वे source को बांटकर common ForkJoinPool पर चलते हैं, जिसे पूरा JVM साझा करता है, तो एक request में एक धीमा parallel stream बाकी सबको देर करा सकता है। इससे हर blocking काम बाहर हो जाता है: मैंने देखा है कि HTTP calls करता एक parallel stream उस process के हर दूसरे parallel stream को भूखा मार देता है। जहां ये सच में मदद करते हैं वह है किसी array या ArrayList पर बड़ी in memory गणना, जो बराबर बंटते हैं, जिसमें कोई साझा mutable state न हो और क्रम पर निर्भरता न हो। तब भी मैं benchmark करता हूं, क्योंकि कुछ हजार elements की collections पर split और merge का ओवरहेड अक्सर फायदा खा जाता है। अगर मुझे अलग pool चाहिए तो मैं stream को common pool की जगह अपने ForkJoinPool के अंदर चलाता हूं।