如何用Java parallelStream提取JSON数组中DataFlagType整数值？

你的代码里有几个明显的逻辑和语法问题，咱们一步步梳理清楚，搞定parallelStream的正确用法：

首先，你在lambda表达式里完全没处理当前遍历的元素x，反而硬编码去取数组的第二个元素，而且语法也不符合Consumer的要求。核心逻辑应该是：遍历JSON数组里的每个对象，逐个取出DataFlagType的整数值。

正确实现方式 #

假设你用的是org.json库（从代码里的JSONArray、JSONObject可以判断），这里有两种实用的写法：

写法1：用forEach处理副作用（比如打印或添加到集合）

JSONArray jsonArray = (JSONArray) json.get("LiveSessionDataCollection");
// 并行流是多线程执行，必须用线程安全的集合存储结果
List<Integer> dataFlagTypeList = Collections.synchronizedList(new ArrayList<>());

jsonArray.parallelStream().forEach(item -> {
    JSONObject sessionObj = (JSONObject) item;
    // 用optInt避免字段不存在时抛出异常，第二个参数是默认值
    int dataFlagType = sessionObj.optInt("DataFlagType", -1);
    dataFlagTypeList.add(dataFlagType);
    // 如果只是打印结果，直接写System.out.println(dataFlagType);即可
});

写法2：用map+collect收集结果（更推荐）

这种方式更贴合Stream API的设计思想，collect方法会自动处理并行流的线程安全收集，不用手动维护线程安全集合：

JSONArray jsonArray = (JSONArray) json.get("LiveSessionDataCollection");

List<Integer> dataFlagTypeList = jsonArray.parallelStream()
    .map(item -> {
        JSONObject sessionObj = (JSONObject) item;
        return sessionObj.optInt("DataFlagType", -1);
    })
    .collect(Collectors.toList());

原代码的问题解析 #

• 你的lambda表达式x -> ((JSONObject) dataFlagType = (JSONObject) jsonArray.get(1))逻辑完全错误：既没有转换当前遍历的元素x，还硬编码取数组的第二个元素，语法上也不符合lambda的规范。
• parallelStream的核心是遍历流中的每个元素，所以你要操作的是lambda参数里的item（也就是原代码里的x），而不是直接操作原JSONArray。

额外提示 #

• 如果你的JSON数组数据量不大，普通stream()和并行流的性能差别很小，甚至普通流更高效（因为并行流存在线程切换开销）。
• 如果你无法保证DataFlagType字段一定存在，务必用optInt()替代getInt()，后者在字段缺失时会抛出JSONException。

内容的提问来源于stack exchange，提问作者john paul