小编jan*_*nko的帖子

在并行Java流中处理随机数

我想从0到50范围内生成5个不同的随机数,然后并行执行一些操作.当我写这个程序时,程序永远不会结束:

new Random().ints(0, 50)
            .distinct()
            .limit(5)
            .parallel()
            .forEach(d -> System.out.println("s: " + d));
Run Code Online (Sandbox Code Playgroud)

我试图使用peek调试它.我有无限的c:行数,50 d:行,但零l:s:行:

new Random().ints(0, 50)
            .peek(d -> System.out.println("c: " + d))
            .distinct()
            .peek(d -> System.out.println("d: " + d))
            .limit(5)
            .peek(d -> System.out.println("l: " + d))
            .parallel()
            .forEach(d -> System.out.println("s: " + d));
Run Code Online (Sandbox Code Playgroud)

我的实施有什么问题?

java parallel-processing java-stream

4
推荐指数
1
解决办法
582
查看次数

标签 统计

java ×1

java-stream ×1

parallel-processing ×1