標簽:
上一篇博文java8函數式編程--收集器collector:(http://my.oschina.net/joshuashaw/blog/487322)講得比較隨性,并沒有把源碼一句一句拿出來分析,后來發現groupingBy方法最后有一個if-else分支用來返回不同類型的collector,一個是不需要特定finisher的,另一個需要使用下游收集器的finisher,今天細看源碼,發現了幾句神奇的代碼,拿出來講一講。
先貼源碼:
public?static?>
Collector?groupingBy(Function?super?T,???extends?K>?classifier,
Supplier?mapFactory,
Collector?super?T,?A,?D>?downstream)?{
Supplier?downstreamSupplier?=?downstream.supplier();
BiConsumer?downstreamAccumulator?=?downstream.accumulator();
BiConsumer,?T>?accumulator?=?(m,?t)?->?{
K?key?=?Objects.requireNonNull(classifier.apply(t),?"element?cannot?be?mapped?to?a?null?key");
A?container?=?m.computeIfAbsent(key,?k?->?downstreamSupplier.get());
downstreamAccumulator.accept(container,?t);
};
BinaryOperator>?merger?=?Collectors.>mapMerger(downstream.combiner());
@SuppressWarnings("unchecked")
Supplier>?mangledFactory?=?(Supplier>)?mapFactory;
if?(downstream.characteristics().contains(Collector.Characteristics.IDENTITY_FINISH))?{
return?new?CollectorImpl<>(mangledFactory,?accumulator,?merger,?CH_ID);
}
else?{
/*---------------------------
----????--神奇的代碼--???------
-----------------------------
@SuppressWarnings("unchecked")
Function?downstreamFinisher?=?(Function)?downstream.finisher();
Function,?M>?finisher?=?intermediate?->?{
intermediate.replaceAll((k,?v)?->?downstreamFinisher.apply(v));
@SuppressWarnings("unchecked")
M?castResult?=?(M)?intermediate;
return?castResult;
};
-----------------------------
-----??---神奇的代碼-----??----
--------------------------*/
return?new?CollectorImpl<>(mangledFactory,?accumulator,?merger,?finisher,?CH_NOID);
}
}
抽出來強調一下
@SuppressWarnings("unchecked")
Function?downstreamFinisher?=?(Function)?downstream.finisher();
Function,?M>?finisher?=?intermediate?->?{
intermediate.replaceAll((k,?v)?->?downstreamFinisher.apply(v));
@SuppressWarnings("unchecked")
M?castResult?=?(M)?intermediate;
return?castResult;
};
這里我們看到,類型為
(Function)?downstream.finisher()
被強制類型轉換成
(Function)?downstreamFinisher
然后是
Map?intermediate
被強制類型轉換成
Map?intermediate
我想,這都行?于是我寫了兩條語句
Fuction?f1?=?Integer::parse;
Fuction?f2?=?(Fuction)?f1;
編譯器報錯。
但是為什么groupingBy方法里面可以這樣寫?于是我按照groupingBy方法寫了一個測試類,代碼如下:
import?java.util.HashMap;
import?java.util.Map;
import?java.util.function.Function;
public?class?InterestingTest?{
private?Map?Tmap?=?null;
private?Map?Vmap?=?null;
private?Function?Vf?=?null;
private?Function?Tf?=?null;
public?InterestingTest(Map?m,Function?f){
Tmap?=?m;
Vf?=?f;
Tf?=?(Function)?f;
Tmap.replaceAll((k,t)->Tf.apply(t));
Vmap?=?(Map)?Tmap;
}
public?Map?getMap(){
return?Vmap;
}
public?static?void?main(String[]?args)?{
Map?map?=?new?HashMap<>();
map.put("1",?1);
map.put("2",?2);
map.put("3",?3);
map.put("4",?4);
Map?newMap?=
new?InterestingTest(map,Integer::toBinaryString)
.getMap();
newMap.entrySet().stream()
.forEach(e->{System.out.println(e.getKey()+"?"+e.getValue());});
}
}
代碼只是報警告,一運行下來一點問題都沒有,完美得出結果。
幾天前刷知乎看到java實現不了真正的泛型,現在算是明白了。
其實,對于java泛型的實現,只是編譯器在編譯階段幫助你進行類型轉型,像Map類型,實際是保存你的對象的地址,對于Map來說,他只是存了Integer的地址,將Integer視為終極父類Object的子類,當你調用get(key)的時候,最后返回Object類型給你之前幫你強制類型轉換成了Integer,就像:
put(key,IntegerObject){
this.object?=?IntegerObject;
}
get(key){
return?(Integer)?findCorrentObject;
}
所以從泛型的角度看,代碼沒有錯誤,但是會警告你這代碼可能導致類型轉換而出現的錯誤,于是我們可以看到
@SuppressWarnings("unchecked")
來去除警告。
但是,當你使用的是具體的類型時,編譯器有職責給你報錯,他認為你寫的這行代碼很有可能發生錯誤。
總結:都是兼容和初始開發人員省事而留下的問題啊。
標簽: