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

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

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

官方寫的很簡單，很隨意...

前三個參數(shù)分別對應了Collector的前三個方法，也就是

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

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

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

static class NumberCollectorImpl implements Collector>, List>>

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

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

這里簡單封了一個小方法createNewList，因為待會還要用

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

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

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

第三個方法BinaryOperator>> combiner()，其實就是兩個List如何合并，當然是addAll方法

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

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

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

綜上所述，完整代碼如下

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

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

    /**
     * 個數(shù)分組器
     * @param 
     */
    static class NumberCollectorImpl implements Collector>, List>> {
        // 每組的個數(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;
        }
    }
}

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

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

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