Java8新特性探索之函数式接口

x -> x.toString()

package java.util.function;

import java.util.Objects;

@FunctionalInterface
public interface Consumer {

    void accept(T t);

    default Consumer andThen(Consumer after) {
        Objects.requireNonNull(after);
        return (T t) -> { accept(t); after.accept(t); };
    }
}

public class ConsumerTest {

 /**
  * 先计算总分，再计算平均分
  */
 @Test
 public void calculate() {
  Integer[] fraction = new Integer[] { 65, 76, 85, 92, 88, 99 };
  consumer(fraction, x -> System.out.println(Arrays.stream(x).mapToInt(Integer::intValue).sum()),
    y -> System.out.println(Arrays.stream(y).mapToInt(Integer::intValue).average().getAsDouble()));
 }
 
 public void consumer(Integer[] fraction, Consumer x, Consumer y) {
  x.andThen(y).accept(fraction);
 }
 
}

package java.util.function;

@FunctionalInterface
public interface Supplier {
    T get();
}

public class SupplierTest {

 public int getMax(Supplier supplier) {
  return supplier.get();
 }
 
 /**
  * 获取数组元素最大值
  */
 @Test
 public void getMaxTest() {
  Integer[] data = new Integer[] { 5, 4, 6, 3, 2, 1 };
  int result = getMax(() -> {
   int max = 0;
   for (int i = 0; i < data.length; i++) {
    max = Math.max(max, data[i]);
   }
   return max;
  });
  System.out.println(result);
 }
 
}

package java.util.function;

import java.util.Objects;

@FunctionalInterface
public interface Function {

    R apply(T t);

    default  Function compose(Function before) {
        Objects.requireNonNull(before);
        return (V v) -> apply(before.apply(v));
    }

    default  Function andThen(Function after) {
        Objects.requireNonNull(after);
        return (T t) -> after.apply(apply(t));
    }

    static  Function identity() {
        return t -> t;
    }
}

public class FunctionTest {
 
 @Test
 public void findByFunctionTest() {
  Function getMoney = m -> m.add(new BigDecimal(1000));
  BigDecimal totalCost = getMoney.apply(new BigDecimal(500));
  System.out.println("张三的钱包原本只有500元，自驾川西得去银行再取1000元，取钱后张三钱包总共有" +           Function.identity().apply(totalCost) + "元");
  BigDecimal surplus = cost(totalCost, (m) -> {
   System.out.println("第二天出发前发现油不足，加油前有" + m + "元");
   BigDecimal lubricate = m.subtract(new BigDecimal(300));
   System.out.println("加油300后还剩余" + lubricate + "元");
   return lubricate;
  }, (m) -> {
   System.out.println("到达景区门口，买景区票前有" + m + "元");
   BigDecimal tickets = m.subtract(new BigDecimal(290));
   System.out.println("买景区票290后还剩余" + tickets + "元");
   return tickets;
  });
  System.out.println("最后张三返程到家还剩余" + surplus + "元");
 }

 public BigDecimal cost(BigDecimal money, Function lubricateCost,
   Function ticketsCost) {
  Function firstNight = (m) -> {
   System.out.println("第一晚在成都住宿前有" + m + "元");
   BigDecimal first = m.subtract(new BigDecimal(200));
   System.out.println("交完200住宿费还剩余" + first + "元");
   return first;
  };
  Function secondNight = (m) -> {
   System.out.println("第二晚在九寨县住宿前有" + m + "元");
   BigDecimal second = m.subtract(new BigDecimal(200));
   System.out.println("交完200住宿费还剩余" + second + "元");
   return second;
  };
  return lubricateCost.andThen(ticketsCost).andThen(secondNight).compose(firstNight).apply(money);
 }

}

张三的钱包原本只有500元，自驾川西得去银行再取1000元，取钱后张三钱包总共有1500元
第一晚在成都住宿前有1500元
交完200住宿费还剩余1300元
第二天出发前发现油不足，加油前有1300元
加油300后还剩余1000元
到达景区门口，买景区票前有1000元
买景区票290后还剩余710元
第二晚在九寨县住宿前有710元
交完200住宿费还剩余510元
最后张三返程到家还剩余510元

package java.util.function;

import java.util.Objects;

@FunctionalInterface
public interface Predicate {

    boolean test(T t);

    default Predicate and(Predicate other) {
        Objects.requireNonNull(other);
        return (t) -> test(t) && other.test(t);
    }

    default Predicate negate() {
        return (t) -> !test(t);
    }

    default Predicate or(Predicate other) {
        Objects.requireNonNull(other);
        return (t) -> test(t) || other.test(t);
    }

    static  Predicate isEqual(Object targetRef) {
        return (null == targetRef)
                ? Objects::isNull
                : object -> targetRef.equals(object);
    }
}

public class PredicateTest {
 /**
  * 查找在渝北的Jack
  */
 @Test
 public void findByPredicateTest() {
  List list = Lists.newArrayList(new User("Johnson", "渝北"), new User("Tom", "渝中"), new User("Jack", "渝北"));
  getNameAndAddress(list, (x) -> x.getAddress().equals("渝北"), (x) -> x.getName().equals("Jack"));
 }
 
 public void getNameAndAddress(List users, Predicate name, Predicate address) {
  users.stream().filter(user -> name.and(address).test(user)).forEach(user -> System.out.println(user.toString()));
 }
}