CollectionUtils扩展方法(注：去重方法中有线程安全问题）

import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang.StringUtils;
 
import com.ibatis.common.beans.Probe;
import com.ibatis.common.beans.ProbeFactory;

public class CollectionUtilsExtends {
    
    private CollectionUtilsExtends (){}
    //1.根据属性名称获取属性值，后面详解
    private static final Probe PROBE = ProbeFactory.getProbe();

  //2.去重list集合中的null值，后面详解
    @SuppressWarnings("rawtypes")
    public static final Collection NULL_COLLECTION = new NullCollection();
      
    @SuppressWarnings("unchecked")
    public static final Collection nullCollection() {
        return (List) NULL_COLLECTION;
    }
    
    
    public static List getAllFormMap(List keys,Map source) {
        List values = Collections.emptyList();
        if (keys != null && !keys.isEmpty() && source != null && !source.isEmpty()) {
            values = new ArrayList();
            for (K k : keys) {
                values.add(source.get(k));
            }
        }
        return values;
    }
    
   
    public static List getValueList(List list, String valueProp) {
        List valueList = Collections.emptyList();
        if (CollectionUtils.isNotEmpty(list)) {
            list.removeAll(nullCollection());
            valueList = new ArrayList(list.size());
            for (E e : list) {
                @SuppressWarnings("unchecked")
                K value = (K)PROBE.getObject(e, valueProp);
                valueList.add(value);
            }
        } 
        return valueList;
    }
    
   
    @SuppressWarnings("unchecked")
    public static Map listforMap(List list, String keyProp, String valueProp) {
        Map map = Collections.emptyMap();
        if (CollectionUtils.isNotEmpty(list)) {
            list.removeAll(nullCollection());
            map = new HashMap(list.size());
            for (E object : list) {
                K key = (K)PROBE.getObject(object, keyProp);
                Object value = null;
                if (StringUtils.isEmpty(valueProp)) {
                    value = object;
                } else {
                    value = PROBE.getObject(object, valueProp);
                }
                map.put(key, (V)value);
            }
        }
        return map;
    }
    
    
    @SuppressWarnings("unchecked")
    public static Map> listforListMap(List list, String keyProp,
            String valueProp) {
        Map> map = Collections.emptyMap();
        if (CollectionUtils.isNotEmpty(list)) {
            list.removeAll(nullCollection());
            map = new HashMap>(list.size());
            V value = null;
            for (E object : list) {
                K key = (K)PROBE.getObject(object, keyProp);
                if (StringUtils.isEmpty(valueProp)) {
                    value = (V)object;
                } else {
                    value = (V)PROBE.getObject(object, valueProp);
                }
                List values = map.get(key);
                if (values == null) {
                    values = new ArrayList();
                }
                values.add(value);
                map.put(key, values);
            }
        }
        return map;
    }

//3.涉及到线程安全问题，后面详解

public static List distinctByKey(List list, String valueProp) {

List resultList = Collections.synchronizedList(new ArrayList<>());

if (list.isEmpty() || StringUtils.isEmpty(valueProp)) {

return null;

}

list.parallelStream().filter(distinctByKey(p -> PROBE.getObject(p, valueProp))).forEach(resultList ::add);
}

public static   Predicate distinctByKey(Function keyExtractor) {

  Map seen = new ConcurrentHashMap<>();

  return t->seen.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null;

}

}

依赖：

    com.ibatis
    ibatis2-common
    2.1.7.597

import java.io.Serializable;  
import java.util.AbstractList;  
import java.util.RandomAccess;  
  
public class NullCollection extends AbstractList