Java函数式编程之Consumer和Predicate

た入场券 2023-06-13 11:15 16阅读 0赞

***欢迎大家访问我的个人博客：[L\_SKH’Blog][L_SKH_Blog]***

# 一、Consumer #

我们先来看它的源码：（我们只来看他第一个方法）它是一个可以传参的接口，拥有一个accept方法。

@FunctionalInterface
    public interface Consumer<T> {
        
    
        /**
         * Performs this operation on the given argument.
         *
         * @param t the input argument
         */
        void accept(T t);
    }

让我们根据它的定义来使用它看看：

import java.util.function.Consumer;
    
    /**
     * @Created IntelliJ IDEA.
     * @Author L_SKH
     * @Date 2019/11/16 19:06
     */
    public class ConsumerApp {
        
        public static void main(String[] args) {
        
            StringBuilder builder = new StringBuilder("SKH");
            Consumer consumer1 = new Consumer<StringBuilder>() {
        
                @Override
                public void accept(StringBuilder stringBuilder) {
        
                    stringBuilder.append("_X") ;
                }
            } ;
            consumer1.accept(builder);
            System.out.println(builder);
    
        }
    
    }

输出:  
SKH\_X  
来看一下集合的一个forEach方法：

@Override
        public void forEach(Consumer<? super E> action) {
        
            Objects.requireNonNull(action);
            final int expectedModCount = modCount;
            @SuppressWarnings("unchecked")
            final E[] elementData = (E[]) this.elementData;
            final int size = this.size;
            for (int i=0; modCount == expectedModCount && i < size; i++) {
        
                action.accept(elementData[i]);
            }
            if (modCount != expectedModCount) {
        
                throw new ConcurrentModificationException();
            }
        }

看到那个Consumer了没，我们来应用一下，同时在jdk8之后有了lambda的使用，我们可以在更加简化一下Consumer的定义：

import java.util.function.Consumer;
    
    /**
     * @Created IntelliJ IDEA.
     * @Author L_SKH
     * @Date 2019/11/16 19:06
     */
    public class ConsumerApp {
        
        public static void main(String[] args) {
        
            StringBuilder builder = new StringBuilder("SKH");
            Consumer<StringBuilder> consumer = (str)->{
        
              str.append("_L") ;
            } ;  //Lambda的应用
            consumer.accept(builder);
            System.out.println(builder);
            ArrayList<Integer> integers = new ArrayList<>();
            integers.add(5) ;
            integers.add(9) ;
            integers.add(8) ;
            integers.add(7) ;
            integers.forEach((data)->{
        
                System.out.println(data);
            });
    
        }
    
    }

# 二、Predicate #

还是来先看他的源码：它也是一个可以传参的接口，与Consumer不同的是它有一个可以返回boolean类型的函数。所以我们可以用它来当做一个filter

@FunctionalInterface
    public interface Predicate<T> {
        
    
        /**
         * Evaluates this predicate on the given argument.
         *
         * @param t the input argument
         * @return {@code true} if the input argument matches the predicate,
         * otherwise {@code false}
         */
        boolean test(T t);
    }

应用：输出一个集合中大于10的元素，我们结合Consumer来编写代码：

package org.skh.c025;
    
    import java.awt.print.Pageable;
    import java.util.ArrayList;
    import java.util.function.Predicate;
    
    /**
     * @Created IntelliJ IDEA.
     * @Author L_SKH
     * @Date 2019/11/16 19:20
     */
    public class PredicateApp {
        
        public static void main(String[] args) {
        
            Predicate<Integer> predicate = (data)->{
        
                if (data>10) {
        
                    return true;
                }
                return false ;
            } ;
            ArrayList<Integer> integers = new ArrayList<>();
            integers.add(5) ;
            integers.add(12) ;
            integers.add(8) ;
            integers.add(11) ;
            integers.forEach((data)->{
        
                if (predicate.test(data)){
        
                    System.out.println(data);
                }else{
        
                    System.out.println("data<10");
                }
            });
    
        }
    }

输出：

data<10
    12
    data<10
    11
    Process finished with exit code 0

[L_SKH_Blog]: http://47.103.221.24