mylist.stream()
.filter(m -> m.isokay() != null)
.forEach(m -> m.dosomething()));
对于此代码,它是否在多个线程上运行?
如果没有,我该怎么办?我想要每个人 m.dosomething()
运行单独的线程来加快这项工作。
mylist.stream()
.filter(m -> m.isokay() != null)
.forEach(m -> m.dosomething()));
对于此代码,它是否在多个线程上运行?
如果没有,我该怎么办?我想要每个人 m.dosomething()
运行单独的线程来加快这项工作。
使用 parallelStream()
实现这一目标。请注意,文档说它“可能是并行的”,因此您可能会返回非并行流。我想这些案例很少见,但要注意它实际上是一个限制。
mylist.parallelStream()
.filter(m -> m.isokay() != null)
.forEach(m -> m.dosomething()));