3

我正在尝试使用 生成随机值SecureRandom，特别是它对流的支持。理想情况下，值应该在恒定的基础上生成，因此流可以是无限的：

SecureRandom secureRandom = new SecureRandom();
Iterator<Integer> idIterator = secureRandom.ints().distinct().iterator();

该文档指出“SecureRandom对象可以安全地被多个并发线程使用。” 但是，当多个线程从迭代器中检索下一个值时，我在（至少）一个似乎是由于竞争条件导致的线程中出现错误：

Thread t1 = new Thread(() -> idIterator.next());
Thread t2 = new Thread(() -> idIterator.next());
t1.start();
t2.start();


Exception in thread "Thread-1" java.lang.IllegalStateException: source already consumed or closed
    at java.base/java.util.stream.AbstractPipeline.sourceSpliterator(AbstractPipeline.java:409)
    at java.base/java.util.stream.AbstractPipeline.lambda$spliterator$0(AbstractPipeline.java:367)
    at java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.init(StreamSpliterators.java:142)
    at java.base/java.util.stream.StreamSpliterators$AbstractWrappingSpliterator.doAdvance(StreamSpliterators.java:157)
    at java.base/java.util.stream.StreamSpliterators$IntWrappingSpliterator.tryAdvance(StreamSpliterators.java:358)
    at java.base/java.util.Spliterators$2Adapter.hasNext(Spliterators.java:726)
    at java.base/java.util.Spliterators$2Adapter.nextInt(Spliterators.java:732)
    at java.base/java.util.PrimitiveIterator$OfInt.next(PrimitiveIterator.java:128)
    at java.base/java.util.PrimitiveIterator$OfInt.next(PrimitiveIterator.java:86)
    at example.Example.foo(Example.java:39)

当我多次运行代码时，有时会得到另一种异常（NullPointerException）。

如果我限制流并删除操作，行为是相同的distinct()：

secureRandom.ints().limit(100).iterator();

编辑：

另一方面，如果我避免使用流而只SecureRandom.nextInt()从每个线程调用，则不会像预期的那样观察到竞争条件。

Thread t1 = new Thread(() -> secureRandom.nextInt());
Thread t2 = new Thread(() -> secureRandom.nextInt());
t1.start();
t2.start(); // code is thread-safe

我想知道为什么迭代器会改变行为？特别是该ints()方法的 Javadocs 声明“生成一个伪随机 int 值，就好像它是调用该方法的结果一样nextInt()”。

PS：我当然可以解决这个问题，但要同步获取下一个值的线程。

4

1 回答 1

1

虽然SecureRandom它本身是线程安全的，但流不是。整个 Streams API 被构建为由单个线程访问。虽然中间操作可以并行执行，但它们必须从单个线程调用。

因此ints()，它的迭代器和它的迭代器都不是线程安全的。

因此，您可以做的是为每个线程创建一个流。

Thread t1 = new Thread(() -> secureRandom.ints().distinct().iterator().next());
Thread t2 = new Thread(() -> secureRandom.ints().distinct().iterator().next());
t1.start();
t2.start();
于 2020-12-02T13:59:14.013 回答