Java 8 - 消费者和Then的使用

2022-09-02 21:56:54

我有下面的POC来使用Java 8功能。

我想在接受方法后更新数据库。搭配好吗?何时调用此方法?谁叫它?andThen()

方法的基本用途是什么?查看文档令人困惑。andThen()

public class StockTest {

    public static void main(String[] args) {

    List<Trader> traders = new ArrayList<>();

    Random random = new Random();

    // Initializing trading a/c's.
    for (int i = 0; i < 10; i++) {
        Trader trader = new Trader((random.nextInt(100) + 1) * 3);
        traders.add(trader);
    }
    // Display Trade accounts.
    System.out.println("Before Bonus, Units are:");
    for (Trader trader : traders) {
        System.out.print(trader.getUnits() + "\t");
    }

    // Add bonus to each trader.
    traders.forEach(new Consumer<Trader>() {

        @Override
        public void accept(Trader trader) {
            trader.updateBonus(2);
        }

        @Override
        public Consumer<Trader> andThen(Consumer<? super Trader> after) 
       {
            System.out.println("In andThen");
            return Consumer.super.andThen(after);
        }
        });

    // Display Trade accounts after bonus applied..
    System.out.println("\nAfter bonus:");
    for (Trader trader : traders) {
        System.out.print(trader.getUnits() + "\t");
     }

   }

 }

 class Trader {
    private int units;

    public Trader(int initialUnits) {
    this.units = initialUnits;
 }

   public int getUnits() {
        return units;
    }

public void setUnits(int units) {
    this.units = units;
}

 public void updateBonus(int bonusUnits) {
    this.units = this.units * bonusUnits;
  }
 }

请通过一些示例或用例来帮助使用此方法


答案 1

简而言之,Then用于链接消费者,因此输入将转到第一个和第二个消费者,如下所示:

Consumer<Trader> consumer1 = new Consumer<Trader>() {

    @Override
    public void accept(Trader trader) {
       trader.updateBonus(2);
    }
};

Consumer<Trader> consumer2 = new Consumer<Trader>() {

    @Override
    public void accept(Trader trader) {
       // do something
    }
};
// Add bonus to each trader.
traders.forEach(consumer1.andThen(consumer2));

所以在这里,交易者将被传递给,然后传递到等等。consumer1consumer2

您不必实现此方法,也不必重写它。当涉及到消费者时,只实现 .accept

andThen方法是加入消费者的帮助器工具。而不是在循环中将输入传递给所有输入。


答案 2

当您想要链接两个 s 的逻辑时,可以使用。 首先调用 的方法,然后调用 的方法。andThenConsumerconsumer1.andThen(consumer2)acceptconsumer1acceptconsumer2

重写 的默认实现没有多大意义,并且会阻止您使用 lambda 表达式/方法引用。andThen

andThen可用于链两个 s:Consumer

traders.forEach(((Consumer<Trader>)(trader -> trader.updateBonus(2))).andThen(trader -> System.out.println("some more processing")));

当然,在这个例子中,你可以简单地把两个 s 的逻辑放在一个单一的:ConsumerConsumer

traders.forEach(trader -> {trader.updateBonus(2);
                           System.out.println("some more processing");});

在链接两个现有 s 时使用更有意义:andThenConsumer

Consumer<Trader> traderConsumer1 = trader -> trader.updateBonus(2);
Consumer<Trader> traderConsumer2 = trader -> System.out.println(trader);
traders.forEach(traderConsumer1.andThen(traderConsumer2));

推荐