应用流的“collec（）”进行计数。运动

Question

我正在尝试创建一个自定义收集器，以便计算列表中的有效元素。我使用了一个已经提供的收集器：

arr.stream()
    .filter(e -> e.matches("[:;][~-]?[)D]"))
    .map(e -> 1)
    .reduce(0, Integer::sum);

但作为对自己的挑战，我想创建自己的定制收藏家，以便更好地理解它。这就是我被卡住的地方。

这可能是一些微不足道的事情，但我正在学习这一点，无法计算供应商、累加器和合路器。我想我还是不了解他们。例如，我有一个类似的流：

arr1.stream()
    .filter(e -> e.matches("[:;][~-]?[)D]"))
    .map(e -> 1)
    .collect(temporary array, adding to array, reduce);

AFAIK supplier是一个没有参数的函数，它返回一些东西。我研究了标准示例，它通常是新集合的方法参考，例如，ArrayList：：new。我尝试使用常量-

我完全被难住了。

Answer 1

您的部分问题可能是，显然无法为整数类型创建累加器，因为它是不可变的。

您可以从以下内容开始：

System.out.println(IntStream.of(1,2,3).reduce(0, Integer::sum));

您可以扩展到此：

System.out.println(IntStream.of(1,2,3).boxed()
    .collect(Collectors.reducing(0, (i1,i2)->i1+i2)));

甚至这个，它有一个中间映射函数

System.out.println(IntStream.of(1,2,3).boxed()
        .collect(Collectors.reducing(0, i->i*2, (i1,i2)->i1+i2)));

你可以用你自己的收藏家走这么远

Collector<Integer, Integer, Integer> myctry = Collector.of(
        ()->0, 
        (i1,i2)->{
            // what to do here?
        }, 
        (i1,i2)->{
            return i1+i2;
        }
    );  

累加器是将值折叠到可变结果容器中的函数，此处的关键字为可变。

那么，做一个可变整数

public class MutableInteger {
    private int value;
    public MutableInteger(int value) {
        this.value = value;
    }
    public void set(int value) {
        this.value = value;
    }
    public int intValue() {
        return value;
    }
}

现在：

Collector<MutableInteger, MutableInteger, MutableInteger> myc = Collector.of(
        ()->new MutableInteger(0), 
        (i1,i2)->{
            i1.set(i1.intValue()+i2.intValue());
        }, 
        (i1,i2)->{
            i1.set(i1.intValue()+i2.intValue());
            return i1;
        }
    );

然后：

System.out.println(IntStream.of(1,2,3)
        .mapToObj(MutableInteger::new)
        .collect(myc).intValue());

参考：使用不同组合器和累加器的流缩减示例

编辑：完成者只是对最终结果做任何事情。如果你不是故意设置的，那么它默认设置为IDENTITY_FINISH，即Function.identity（），表示只按原样返回最终结果。

编辑：如果你真的很绝望：

Collector<int[], int[], int[]> mycai = Collector.of(
        ()->new int[1], 
        (i1,i2)->i1[0] += i2[0], 
        (i1,i2)->{i1[0] += i2[0]; return i1;}
    );
System.out.println(IntStream.of(1,2,3)
        .mapToObj(v->{
            int[] i = new int[1];
            i[0] = v;
            return i;
        })
        .collect(mycai)[0]);