Java函数式编程如何与传统线程同步机制结合实现并行计算？

List<Integer> numbers = List.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);

// 创建并行流
Stream<Integer> parallelStream = numbers.stream().parallel();

// 并行处理
int sum = parallelStream
    .filter(n -> n % 2 == 0) // 仅保留偶数
    .map(n -> n * n) // 计算每个偶数的平方
    .reduce(0, Integer::sum); // 求偶数平方の和

System.out.println("偶数平方的和：" + sum);

// 创建一个共享的集合
ConcurrentHashMap<String, Integer> sharedMap = new ConcurrentHashMap<>();

// 创建一个锁对象
final Object lock = new Object();

// 并行地将键值对添加到共享集合中
numbers.parallelStream()
    .forEach(n -> {
        // 为共享集合加锁
        synchronized (lock) {
            sharedMap.put("key" + n, n);
        }
    });

// 定义一个方法计算两个矩阵的乘积
static int[][] multiplyMatrices(int[][] matrix1, int[][] matrix2) {
    int rows1 = matrix1.length;
    int cols1 = matrix1[0].length;
    int rows2 = matrix2.length;
    int cols2 = matrix2[0].length;

    if (cols1 != rows2) {
        throw new IllegalArgumentException("矩阵无法相乘");
    }

    // 创建并行流
    Stream<int[]> parallelRows = Arrays.stream(matrix1)
        .parallel();

    // 使用并行处理计算每行的结果
    int[][] result = parallelRows
        .map(row1 -> {
            int[] rowResult = new int[cols2];
            for (int c = 0; c < cols2; c++) {
                for (int k = 0; k < rows2; k++) {
                    rowResult[c] += row1[k] * matrix2[k][c];
                }
            }
            return rowResult;
        })
        .toArray(int[][]::new);

    return result;
}