如何使用流并行和filter及findFirst短路

Question

我有一个具有不同复杂性（进程持续时间）的txntype列表。
我想从列表中找到匹配的txntype。
我试图通过混合流的并行处理和短路过滤功能来实现它。
但我注意到它们没有混合。
我编写了下面的示例。但注意到并行和短路的混合不能正常工作。
每次运行都显示并行处理在工作，但在找到项目时没有终止！！！

    class TxnType {
        public String id;   
        public TxnType(String id) {this.id = id;}
       
        public boolean match(String entry) {
            Date s = new Date();
            // simulate long processing match time TxnType
            if (id.equals("1")) {
                try {
                    Thread.sleep(4000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            Date f = new Date();
            System.out.println("check id = " + id+ "  duration = "+(f.getTime()- s.getTime()));
    
            return id.equalsIgnoreCase(entry);
        }
    }

     private void test4() {
        // build list of available TxnTypes
        ArrayList<TxnType> lst = new ArrayList<>();
        lst.add(new TxnType("0"));
        lst.add(new TxnType("1"));  // long match processing time type
        lst.add(new TxnType("2"));
        lst.add(new TxnType("3"));
        lst.add(new TxnType("4"));

        String searchFor = "3";
        System.out.println("searchFor = " + searchFor);
        Date st, fi;

        st = new Date();
        Optional<TxnType> found2 =lst.stream().parallel().filter(txnType->txnType.match(searchFor)).findFirst();
            System.out.println("found.stream().count() = " + found2.stream().count());
            fi= new Date();
            System.out.println("dur="+ (fi.getTime()- st.getTime()));
    }

通过多次运行，我发现处理没有尽快终止，并等待处理所有这些！！！！

searchFor = 3
check id = 4  duration = 0
check id = 2  duration = 0
check id = 3  duration = 0
check id = 0  duration = 0
check id = 1  duration = 4005
found.stream().count() = 1
dur=4050

是否存在类似filterfindfirst()的内容？

Answer 1

您的错误是使用findfirst，而不是findany。

请注意，1被排序在您期望找到的元素之前(3)。因此，它必须首先完成对1的检查，然后才能得出“3是第一个匹配谓词的元素”的结论，即使它们是并行执行的。如果它找到了3，并且还没有开始检查列表下面的内容，那么它就不会开始检查。这就是findfirst中的短路的含义。

另一方面，findany并不关心顺序。如果它发现任何满足谓词的元素，它就不再开始检查任何新的元素。

for (int i = 0 ; i < 100 ; i++) {
    lst.add(new TxnType("foo"));
}

...

Optional<TxnType> found2 = lst.parallelStream().filter(txnType -> txnType.match(searchFor)).findAny();

基本上，短路工作正常。只是

• FindFirst不会像您希望的那样严重短路
• 列表中的元素太少，而您的计算机有足够的核心来一次处理所有这些元素，因此确实如此。