Function parallel_reduce_edge_count

nodedb/src/engine/graph/olap/parallel.rs:262–283

()

    #[test]
    fn parallel_reduce_edge_count() {
        let snap = make_snapshot();
        let config = ParallelConfig {
            num_threads: 4,
            min_partition_size: 10,
        };

        let total_edges: usize = parallel_reduce(
            &snap,
            &config,
            |range, s| {
                let mut count = 0;
                for node in range.start..range.end {
                    count += s.out_degree_raw(node);
                }
                count
            },
            |partials| partials.into_iter().sum(),
        );

        assert_eq!(total_edges, 100);
    }

    #[test]
    fn parallel_map_single_thread() {