Java 8 Akış mizanpajı

Question

mylist.stream() 
     .filter(m -> m.isokay() != null) 
     .forEach(m -> m.dosomething())); 

Bu kod için birden çok iş parçacığı üzerinde çalışıyor mu? Değilse nasıl yapabilirim? Bu çalışmayı hızlandırmak için her bir m.dosomething()'un ayrı iş parçacığı üzerinde çalışmasını istiyorum. Bunu gerçekleştirmek için parallelStream() kullanın.

Answer 1

Dokümantasyonun "muhtemelen paralel" olduğunu belirttiğine dikkat edin, bu nedenle paralel olmayan bir akışı döndürebilirsiniz. Bu vakaların nadir olduğunu düşünürdüm, ama aslında bunun bir sınırlama olduğunun farkında ol.

mylist.parallelStream() 
     .filter(m -> m.isokay() != null) 
     .forEach(m -> m.dosomething()));