方法中有泛型，所以要先要介紹哈Collector中的三個(gè)泛型T, A, R
T：stream在調(diào)用collect方法收集前的數(shù)據(jù)類型
A：A是T的累加器，遍歷T的時(shí)候，會(huì)把T按照一定的方式添加到A中，換句話說(shuō)就是把一些T通過(guò)一種方式變成A
R：R可以看成是A的累加器，是最終的結(jié)果，是把A匯聚之后的數(shù)據(jù)類型，換句話說(shuō)就是把一些A通過(guò)一種方式變成R

了解了泛型的意思，咱們結(jié)合Collectors.toList構(gòu)造的默認(rèn)實(shí)現(xiàn)類的實(shí)現(xiàn)方式來(lái)看看Collector接口的方法

public static 
    Collector> toList() {
        return new CollectorImpl<>((Supplier>) ArrayList::new, List::add,
                                   (left, right) -> { left.addAll(right); return left; },
                                   CH_ID);
    }

官方寫的很簡(jiǎn)單，很隨意...

前三個(gè)參數(shù)分別對(duì)應(yīng)了Collector的前三個(gè)方法，也就是

再來(lái)看看第四個(gè)方法Function finisher()，其實(shí)就是怎么把A轉(zhuǎn)化為R，由于是toList，所以A和R是一樣的類型，這里其實(shí)用就是Function.identity
最后第五個(gè)方法Set characteristics()其實(shí)就是這個(gè)Collector的一些性質(zhì)，toList這里只用了Characteristics.IDENTITY_FINISH，表示第四個(gè)方法可以不用設(shè)置，A類型就是最終的結(jié)果

=====================（Collector介紹完了）==================

現(xiàn)在創(chuàng)建自定義的collector，類名我就叫NumberCollectorImpl，由于collector這里要求有三個(gè)泛型，根據(jù)題主的需求，這三個(gè)泛型只有第一個(gè)是未知的，另外兩個(gè)應(yīng)該是確認(rèn)的List結(jié)構(gòu)，所以寫出來(lái)應(yīng)該是這么個(gè)效果

static class NumberCollectorImpl implements Collector>, List>>

ok，針對(duì)collector要求實(shí)現(xiàn)的5個(gè)方法來(lái)依次說(shuō)明
第一個(gè)方法Supplier>> supplier()，很明顯應(yīng)該就是ArrayList::new
第二個(gè)方法BiConsumer>, T>，這個(gè)稍微麻煩點(diǎn)，起始應(yīng)該寫成(list, item) -> {}，主要就是補(bǔ)充{}中的代碼了
最開始的遍歷的時(shí)候，這個(gè)list其實(shí)是父list，它肯定是空的，所以這個(gè)時(shí)候要?jiǎng)?chuàng)建一個(gè)新子List，然后把item塞進(jìn)子list中，最后再把創(chuàng)建的新子list放入到父list中

if (list.isEmpty()){
  list.add(this.createNewList(item));
}

這里簡(jiǎn)單封了一個(gè)小方法createNewList，因?yàn)榇龝?huì)還要用

private List createNewList(T item){
   List newOne = new ArrayList();
   newOne.add(item);
   return newOne;
}

若父list不為空，那就要把當(dāng)前父list中最后一個(gè)子list取出來(lái)，若空的話，當(dāng)然又是要?jiǎng)?chuàng)建一個(gè)新子list然后按照之前的方法做，若不為空，就判斷子list大小咯，若大小超過(guò)2，就再次創(chuàng)建一個(gè)新子list然后塞item，若沒(méi)有超過(guò)就在之前子list中塞入item，寫出來(lái)大概就是這個(gè)樣子

List last = (List) list.get(list.size() - 1);
if (last.size() < 2){
    last.add(item);
}else{
    list.add(this.createNewList(item));
}

第三個(gè)方法BinaryOperator>> combiner()，其實(shí)就是兩個(gè)List如何合并，當(dāng)然是addAll方法

(list1, list2) -> {
   list1.addAll(list2);
   return list1;
};

第四個(gè)方法Function>, List>> finisher()，由于這個(gè)時(shí)候A和R的類型一樣，都是List>，所以這里直接就是Function.identity()啦

最后一個(gè)方法Set characteristics()這里直接可以按照Collectors.toList來(lái)弄就行了，也就是直接采用Collections.unmodifiableSet(EnumSet.of(Collector.Characteristics.IDENTITY_FINISH))

綜上所述，完整代碼如下

/**
 * 自定義Collector
 *
 * @author imango
 * @since 2017/7/13
 */
public class CustomCollectors {

    // 默認(rèn)采用2個(gè)一起分組
    public static  Collector>, List>> groupByNumber(){
        return CustomCollectors.groupByNumber(2);
    }
    
    // 根據(jù)number的大小進(jìn)行分組
    public static  Collector>, List>> groupByNumber(int number){
        return new NumberCollectorImpl(number);
    }

    /**
     * 個(gè)數(shù)分組器
     * @param 
     */
    static class NumberCollectorImpl implements Collector>, List>> {
        // 每組的個(gè)數(shù)
        private int number;

        public NumberCollectorImpl(int number) {
            this.number = number;
        }

        @Override
        public Supplier>> supplier() {
            return ArrayList::new;
        }

        @Override
        public BiConsumer>, T> accumulator() {
            return (list, item) -> {
                if (list.isEmpty()){
                    list.add(this.createNewList(item));
                }else {
                    List last = (List) list.get(list.size() - 1);
                    if (last.size() < number){
                        last.add(item);
                    }else{
                        list.add(this.createNewList(item));
                    }
                }
            };
        }

        @Override
        public BinaryOperator>> combiner() {
            return (list1, list2) -> {
                list1.addAll(list2);
                return list1;
            };
        }

        @Override
        public Function>, List>> finisher() {
            return Function.identity();
        }

        @Override
        public Set characteristics() {
            return Collections.unmodifiableSet(EnumSet.of(Collector.Characteristics.IDENTITY_FINISH));
        }

        private List createNewList(T item){
            List newOne = new ArrayList();
            newOne.add(item);
            return newOne;
        }
    }
}

外面那個(gè)類CustomCollectors 主要是為了封裝NumberCollectorImpl類，以后也可以把其他自定義的收集器實(shí)現(xiàn)放在這里面，并對(duì)外提供工具方法，并且我在NumberCollectorImpl類中新增了一個(gè)number成員變量，這樣就可以自定義分組大小了，CustomCollectors提供了兩個(gè)對(duì)外方法groupByNumber，帶參數(shù)的那個(gè)就是可以自定義分組個(gè)數(shù)的了，沒(méi)有參數(shù)的就是默認(rèn)按照2個(gè)分組了，這樣的話，測(cè)試寫法就是這樣

public static void main(String[] args) {
   List list = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
   // 按照2個(gè)分組
   List> twoNumberList = list.stream().collect(CustomCollectors.groupByNumber());
   // 按照5個(gè)分組
   List> fiveNumberList = list.stream().collect(CustomCollectors.groupByNumber(5));
}

這樣代碼就非常漂亮了~哈哈哈~~