stream.forEach中的多行代码

Question

我有以下代码来读取文件的行:

String fileName = "dataset/ANC-all-count.txt";
Integer i=0;
//read file into stream, try-with-resources
try (Stream<String> stream = Files.lines(Paths.get(fileName), StandardCharsets.ISO_8859_1)) {

    stream.forEach(System.out::println);
    i++;

} catch (IOException e) {
    e.printStackTrace();
}
System.out.println("count is : "+i);

但问题是我需要放入i++以下行:

stream.forEach(System.out::println);

所以我想要这样的东西:

stream.forEach(System.out::println; i++);

但它不能以这种方式工作,所以任何人都可以帮助我如何使它工作？

Answer 1

您应该在这里问两件完全不同的事情：

a)如何将多行代码放入stream.forEach()？

b)我应该怎么做才能计算 a 中的行数Stream？

b)其他海报已经回答了这个问题；另一方面，一般问题a)有一个完全不同的答案：

使用（可能是多行的）lambda 表达式或传递对多行方法的引用。

在这种特殊情况下，您要么声明i一个字段，要么使用计数器/包装器对象而不是i.

例如，如果你想在forEach() 显式中有多行，你可以使用

class Counter { // wrapper class
    private int count;
    public int getCount() { return count; }
    public void increaseCount() { count++; }
}

进而

Counter counter = new Counter();
lines.stream().forEach( e -> {
    System.out.println(e);
    counter.increaseCounter(); // or i++; if you decided i is worth being a field
} );

另一种方法，这次将这些多行隐藏在一个方法中：

class Counter { // wrapper class
    private int count;
    public int getCount() { return count; }
    public void increaseCount( Object o ) {
        System.out.println(o);
        count++;
    }
}

进而

Counter counter = new Counter();
lines.stream().forEach( counter::increaseCount );

甚至

Counter counter = new Counter();
lines.stream().forEach( e -> counter.increaseCount(e) );

如果您需要具有多个参数的使用者，则第二种语法会派上用场；尽管如此，第一种语法仍然是最短和最简单的。

Answer 2

该forEach方法采用任何实现的类的实例Consumer.所以这是一个使用自定义Consumer实现来跟上计数的例子.以后你可以叫getCount()上Consumer执行得到计数.

import java.util.ArrayList;
import java.util.List;
import java.util.function.Consumer;

public class ConsumerDemo {
    public static void main(String[] args) {
        List<String> lines = new ArrayList<String>();
        lines.add("line 1");
        lines.add("line 2");

        MyConsumer countingConsumer = new MyConsumer();
        lines.stream().forEach(countingConsumer);
        System.out.println("Count: " + countingConsumer.getCount());
    }

    private static class MyConsumer implements Consumer<String> {
        private int count;

        @Override
        public void accept(String t) {
            System.out.println(t);
            count++;
        }

        public int getCount() {
            return count;
        }
    }
}

Answer 3

使用peek()和count():

i = (int) stream.peek(System.out::println) 
                .count();