通过Consumer函数式接口，实现回调

比如有场景：A类服务List集合传入到Consumer接口中，Consumer接口实现批量解析List，当解析一定数量后，回调A类中的方法，进行下一步操作(比如加入数据库)。

代码定义如下：

1、Test类：

public class Test {
    public static void main(String[] args) throws Exception {
        test();
    }

    public static void test() throws Exception {
        // 模拟数据
        List<User> userList = new ArrayList<>();
        for (int a = 0; a < 10000; a++) {
            User user = new User();
            user.setUsername("用户：" + a);
            userList.add(user);
        }

        Consumer<List<User>> consumer =
                uploadData -> importData(uploadData);
        // 调用B类
        new MyConsumer(consumer).handlerData(userList);
    }


    /**
     * 创建回调方法
     */
    public static void importData(List<User> list) {
        // 插入到数据库中
        System.out.println("解析数量：" + list.size());
    }
}

2、MyConsumer类

public class MyConsumer<T> {

    /**
     * 传入解析数据的service对象
     */
    public Consumer<List<T>> uploadService;


    public MyConsumer(Consumer<List<T>> uploadService) throws Exception {
        this.uploadService = uploadService;
    }

    /**
     * 处理数据
     */
    public void handlerData(List<T> list) {
        // 模拟解析，每30条数据就进行回调
        List<T> dataList = new ArrayList<>();
        for (T t : list) {
            dataList.add(t);
            if (dataList.size() == 1000) {
                // 回调保存数据
                saveData(dataList);
            }
        }

        // 回调保存数据
        saveData(dataList);
    }


    /**
     * 回调保存数据
     *
     * @param dataList
     */
    private void saveData(List<T> dataList) {
        if (dataList.size() > 0) {
            uploadService.accept(dataList);
            dataList.clear();
        }
    }
}

效果：

3、处理逻辑：
在Test类中，有一个List集合大小为10000，有一个解析类MyConsumer，负责对List数据进行解析操作，并且将解析的数据插入到数据库中，但是为了防止数据一次插入的数据过多需要分批次插入，所以MyConsumer负责解析，并且每解析1000条数据就回调Test类，由Test类负责插入数据到数据库中。

4、注意：
此处只是列举了，通过Consumer实现数据解析的回调，实际开发中还是存在其他的情况，一样可以使用到Consumer回调机制。