Операция сбора в Java 8 Stream API определяется как изменяемое сокращение, которое можно безопасно выполнять параллельно, даже если результирующее Collection не является потокобезопасным.
Можем ли мы сказать то же самое о методе Stream.toArray()?
Является ли этот метод изменяемым сокращением, которое является потокобезопасным, даже если Stream является параллельным потоком, а результирующий массив не является потокобезопасным?
Операция toArray является разновидностью изменяемой редукции, хотя и не реализована точно так же, как операция collect. Напротив, в некоторых случаях это более эффективно. Но это неуказанные детали реализации. Сама документация toArray ничего не говорит о том, как она реализована, поэтому по вашему вопросу вам придется прибегнуть к более общим утверждениям:
… Все операции с потоками могут выполняться как последовательно, так и параллельно.
…
За исключением операций, определенных как явно недетерминированные, таких как
findAny(), независимо от того, выполняется ли поток последовательно или параллельно, результат вычислений не должен меняться.…
Большинство потоковых операций принимают параметры, описывающие заданное пользователем поведение, которые часто представляют собой лямбда-выражения. Чтобы сохранить правильное поведение, эти поведенческие параметры должны быть не влияющими и в большинстве случаев должны быть без сохранения состояния.
Таким образом, независимо от того, как это реализовано, toArray является потоковой операцией, которая может выполняться параллельно, и, поскольку она не имеет каких-либо ограничений или недетерминированного поведения, она будет давать тот же (правильный) результат, что и в последовательном режиме. Это единственное, о чем вы должны думать.
Но если вы используете перегруженный метод toArray(IntFunction), вы несете ответственность за предоставление соответствующей функции, например. SomeType[]::new всегда невмешательна и не имеет состояния, поэтому форма toArray(SomeType[]::new) также является потокобезопасной.
Согласно https://docs.oracle.com/javase/8/docs/api/java/util/stream/Stream.html#toArray-java.util.function.IntFunction- так и должно быть, поскольку они создают
... любые дополнительные массивы, которые могут потребоваться для секционированного выполнения или для изменения размера
И в дедукции, поскольку Stream.toArray() есть не что иное, как stream.toArray(Object[]::new), это должно быть верно и для Stream.toArray().
