java8中parallelStream性能测试及结果分析

2025-05-29 0 38

测试1

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49
@BenchmarkMode(Mode.AverageTime)

@OutputTimeUnit(TimeUnit.NANOSECONDS)

@Warmup(iterations = 5, time = 3, timeUnit = TimeUnit.SECONDS)

@Measurement(iterations = 20, time = 3, timeUnit = TimeUnit.SECONDS)

@Fork(1)

@State(Scope.Benchmark)

public class StreamBenchTest {

List<String> data = new ArrayList<>();

@Setup

public void init() {

// prepare

for(int i=0;i<100;i++){

data.add(UUID.randomUUID().toString());

}

}

@TearDown

public void destory() {

// destory

}

@Benchmark

public void benchStream(){

data.stream().forEach(e -> {

e.getBytes();

try {

Thread.sleep(10);

} catch (InterruptedException e1) {

e1.printStackTrace();

}

});

}

@Benchmark

public void benchParallelStream(){

data.parallelStream().forEach(e -> {

e.getBytes();

try {

Thread.sleep(10);

} catch (InterruptedException e1) {

e1.printStackTrace();

}

});

}

public static void main(String[] args) throws RunnerException {

Options opt = new OptionsBuilder()

.include(".*" +StreamBenchTest.class.getSimpleName()+ ".*")

.forks(1)

.build();

new Runner(opt).run();

}

}

parallelStream线程数

默认是Runtime.getRuntime().availableProcessors() – 1,这里为7

运行结果

?

1

2

3

4
# Run complete. Total time: 00:02:44

Benchmark Mode Cnt Score Error Units

StreamBenchTest.benchParallelStream avgt 20 155868805.437 ± 1509175.840 ns/op

StreamBenchTest.benchStream avgt 20 1147570372.950 ± 6138494.414 ns/op

测试2

将数据data改为30,同时sleep改为100

?

1

2

3
Benchmark Mode Cnt Score Error Units

StreamBenchTest.benchParallelStream avgt 20 414230854.631 ± 725294.455 ns/op

StreamBenchTest.benchStream avgt 20 3107250608.500 ± 4805037.628 ns/op

可以发现sleep越长,parallelStream优势越明显。

小结

parallelStream在阻塞场景下优势更明显,其线程池个数默认为
Runtime.getRuntime().availableProcessors() – 1,如果需修改则需设置-Djava.util.concurrent.ForkJoinPool.common.parallelism=8

以上就是本次讲述知识点的全部内容,感谢你对快网idc的支持。

原文链接:https://segmentfault.com/a/1190000012755594

收藏 (0) 打赏

感谢您的支持,我会继续努力的!

打开微信/支付宝扫一扫,即可进行扫码打赏哦,分享从这里开始,精彩与您同在
点赞 (0)

声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。

快网idc优惠网 建站教程 java8中parallelStream性能测试及结果分析 https://www.kuaiidc.com/113096.html

相关文章

发表评论
暂无评论