如何使用 java 8 中的流将集合/数组转换为 JSONArray

Question

我有一个双数组，我需要使用 java streams 将数组转换为 JSONArray。我尝试使用导致数据丢失的 forEach（共享可变性）。

public static JSONArray arrayToJson(double[] array) throws JSONException{
    JSONArray jsonArray = new JSONArray();
    
    Arrays.stream(array)
         .forEach(jsonArray::put);  

    return jsonArray;
}

有什么方法可以使用流创建JSONArray？

Answer 1

您的代码有效，但您可以编写如下内容 (jdk 8+)：

return Arrays.stream(array)
             .collect(Collector.of(
                          JSONArray::new, //init accumulator
                          JSONArray::put, //processing each element
                          JSONArray::put  //confluence 2 accumulators in parallel execution
                     ));

另一个例子（从List<String>创建一个String）：

List<String> list = ...
String str = list.stream()
                 .collect(Collector.of(
                    StringBuilder::new,
                    StringBuilder::append,
                    StringBuilder::append,
                    StringBuilder::toString //last action of the accumulator (optional)  
                 ));

看起来不错，但编译器抱怨：error: incompatible thrown types JSONException in method reference .collect(Collector.of(JSONArray::new, JSONArray::put, JSONArray::put)

我在jdk 13.0.1 和JSON 20190722 上检查了这个问题，除了.collect(...) 中的Expected 3 arguments, but found 1 之外没有发现问题。

(Gradle : implementation group: 'org.json', name: 'json', version: '20190722')

---

修复：

public static JSONArray arrayToJson(double[] array) throws JSONException {
    return Arrays.stream(array).collect(
            JSONArray::new,
            JSONArray::put,
            (ja1, ja2) -> {
                for (final Object o : ja2) {
                    ja1.put(o);
                }
            }
    );
}

注意：组合器不能只是对JSONArray::put 的方法引用，因为这只会将一个数组放入另一个数组（例如[[]]），而不是按照期望的行为实际组合它们.

Answer 2

JSONArray 不是线程安全的。如果你使用并行流，你应该同步操作。

Arrays
    .stream(array)
    .parallel()
    .forEach(e -> {
        synchronized(jsonArray) {
            jsonArray.put(e);
        }
    });