发现了个很奇怪的现象，关于 parallelStream 的

• 请不要在回答技术问题时复制粘贴 AI 生成的内容

This topic created in 1664 days ago, the information mentioned may be changed or developed.

这个接口的处理类似这样

List<Data> dataList = xxx.paralleStream().map(e->dealData(e)).collect(Collector.toList());

其中有的 dealData 会用 http 调用外部接口。我在每个 dealData 都打印了时间，基本都在 50ms 左右徘徊。按理说这个方法的处理时间应该是耗时最长的那个，但是最终结果却差的很远。这个接口除了并发流基本就没什么操作了。服务器间的时延可以忽略不计。好神奇

Supplement 1 · Oct 28, 2021

public static void test1() throws ExecutionException, InterruptedException {
        ForkJoinPool forkJoinPool = new ForkJoinPool(4);
        for( int i=0;i<1000;i++) {
            int index = i;
            long time = System.currentTimeMillis();
            List<String> list = forkJoinPool.submit(() -> Stream.of(ary).parallel().map(s -> getString(index)).collect(Collectors.toList())).get();
            System.out.println("cost time :" + (System.currentTimeMillis() - time));

        }   
    }
    
    public static void test2(){
        for( int i=0;i<1000;i++) {
            int index = i;
            long time = System.currentTimeMillis();
            List<String> list = Stream.of(ary).parallel().map(s -> getString(index)).collect(Collectors.toList());
            System.out.println("cost time :" + (System.currentTimeMillis() - time));

        }
    }


    public static String getString(int index) {
        int i = new Random().nextInt(50);
        try {
            Thread.sleep(i);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + ":" +index + "cost time " + i);
        return "";
    }

试着跑了一下，test1自定义线程池之后，会一直用到池里面的线程。 test2用的共享池，竟然还会用主线程main在跑。所以时间差距是不是在这块。

Supplement 2 · Oct 29, 2021

public static void test1() throws ExecutionException, InterruptedException {
        ForkJoinPool forkJoinPool = new ForkJoinPool(30);
        long time = System.currentTimeMillis();
        List<String> list = forkJoinPool.submit(() -> Stream.of(ary).parallel().map(s -> getString()).collect(Collectors.toList())).get();
        System.out.println("cost time :" + (System.currentTimeMillis() - time));

    }

public static String getString() {
        int i = new Random().nextInt(50);
        try {
            Thread.sleep(i);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "";
    }

我用jmeter20并发压测发现，这个性能也并不是很好。要比50ms多两倍多

dealdata

List

接口

estr

13 replies • 2021-11-01 22:27:55 +08:00