Java 8中用法優(yōu)雅的Stream,性能也"優(yōu)雅"嗎?
之前的文章中我們介紹了Java 8中Stream相關(guān)的API,我們提到Stream API可以極大提高Java程序員的生產(chǎn)力,讓程序員寫(xiě)出高效率、干凈、簡(jiǎn)潔的代碼。
那么,Stream API的性能到底如何呢,代碼整潔的背后是否意味著性能的損耗呢?本文我們對(duì)Stream API的性能一探究竟。
為保證測(cè)試結(jié)果真實(shí)可信,我們將JVM運(yùn)行在-server模式下,測(cè)試數(shù)據(jù)在GB量級(jí),測(cè)試機(jī)器采用常見(jiàn)的商用服務(wù)器,配置如下:
OS |
CentOS 6.7 x86_64 |
CPU |
Intel Xeon X5675, 12M Cache 3.06 GHz, 6 Cores 12 Threads |
內(nèi)存 |
96GB |
JDK |
java version 1.8.0_91, Java HotSpot(TM) 64-Bit Server VM |
1.測(cè)試方法與數(shù)據(jù)
性能測(cè)試并不是容易的事,Java性能測(cè)試更費(fèi)勁,因?yàn)樘摂M機(jī)對(duì)性能的影響很大,JVM對(duì)性能的影響有兩方面:
1.GC的影響。GC的行為是Java中很不好控制的一塊,為增加確定性,我們手動(dòng)指定使用CMS收集器,并使用10GB固定大小的堆內(nèi)存。具體到JVM參數(shù)就是-XX:+UseConcMarkSweepGC -Xms10G -Xmx10G
2.JIT(Just-In-Time)即時(shí)編譯技術(shù)。即時(shí)編譯技術(shù)會(huì)將熱點(diǎn)代碼在JVM運(yùn)行的過(guò)程中編譯成本地代碼,測(cè)試時(shí)我們會(huì)先對(duì)程序預(yù)熱,觸發(fā)對(duì)測(cè)試函數(shù)的即時(shí)編譯。相關(guān)的JVM參數(shù)是-XX:CompileThreshold=10000。
Stream并行執(zhí)行時(shí)用到ForkJoinPool.commonPool()得到的線程池,為控制并行度我們使用Linux的taskset命令指定JVM可用的核數(shù)。
測(cè)試數(shù)據(jù)由程序隨機(jī)生成。為防止一次測(cè)試帶來(lái)的抖動(dòng),測(cè)試4次求出平均時(shí)間作為運(yùn)行時(shí)間。
2.基本類型迭代
測(cè)試內(nèi)容:找出整型數(shù)組中的最小值。對(duì)比f(wàn)or循環(huán)外部迭代和Stream API內(nèi)部迭代性能。
測(cè)試程序IntTest,測(cè)試結(jié)果如下圖:
圖中展示的是for循環(huán)外部迭代耗時(shí)為基準(zhǔn)的時(shí)間比值。分析如下:
- 對(duì)于基本類型Stream串行迭代的性能開(kāi)銷(xiāo)明顯高于外部迭代開(kāi)銷(xiāo)(兩倍);
- Stream并行迭代的性能比串行迭代和外部迭代都好。
并行迭代性能跟可利用的核數(shù)有關(guān),上圖中的并行迭代使用了全部12個(gè)核,為考察使用核數(shù)對(duì)性能的影響,我們專門(mén)測(cè)試了不同核數(shù)下的Stream并行迭代效果:
分析,對(duì)于基本類型:
- 使用Stream并行API在單核情況下性能很差,比Stream串行API的性能還差;
- 隨著使用核數(shù)的增加,Stream并行效果逐漸變好,比使用for循環(huán)外部迭代的性能還好。
以上兩個(gè)測(cè)試說(shuō)明,對(duì)于基本類型的簡(jiǎn)單迭代,Stream串行迭代性能更差,但多核情況下Stream迭代時(shí)性能較好。
2.對(duì)象迭代
接下來(lái)我們?cè)賮?lái)看對(duì)象的迭代效果。
測(cè)試內(nèi)容:找出字符串列表中最小的元素(自然順序),對(duì)比f(wàn)or循環(huán)外部迭代和Stream API內(nèi)部迭代性能。
測(cè)試程序StringTest,測(cè)試結(jié)果如下圖:
結(jié)果分析如下:
- 對(duì)于對(duì)象類型Stream串行迭代的性能開(kāi)銷(xiāo)仍然高于外部迭代開(kāi)銷(xiāo)(1.5倍),但差距沒(méi)有基本類型那么大。
- Stream并行迭代的性能比串行迭代和外部迭代都好。
再來(lái)單獨(dú)考察Stream并行迭代效果:
分析,對(duì)于對(duì)象類型:
- 使用Stream并行API在單核情況下性能比f(wàn)or循環(huán)外部迭代差;
- 隨著使用核數(shù)的增加,Stream并行效果逐漸變好,多核帶來(lái)的效果明顯。
以上兩個(gè)測(cè)試說(shuō)明,對(duì)于對(duì)象類型的簡(jiǎn)單迭代,Stream串行迭代性能更差,但多核情況下Stream迭代時(shí)性能較好。
3.復(fù)雜對(duì)象歸約
從實(shí)驗(yàn)一、二的結(jié)果來(lái)看,Stream串行執(zhí)行的效果都比外部迭代差(很多),是不是說(shuō)明Stream真的不行了?先別下結(jié)論,我們?cè)賮?lái)考察一下更復(fù)雜的操作。
測(cè)試內(nèi)容:給定訂單列表,統(tǒng)計(jì)每個(gè)用戶的總交易額。對(duì)比使用外部迭代手動(dòng)實(shí)現(xiàn)和Stream API之間的性能。
我們將訂單簡(jiǎn)化為<userName, price, timeStamp>構(gòu)成的元組,并用Order對(duì)象來(lái)表示。測(cè)試程序ReductionTest,測(cè)試結(jié)果如下圖:
分析,對(duì)于復(fù)雜的歸約操作:
- Stream API的性能普遍好于外部手動(dòng)迭代,并行Stream效果更佳;
再來(lái)考察并行度對(duì)并行效果的影響,測(cè)試結(jié)果如下:
分析,對(duì)于復(fù)雜的歸約操作:
使用Stream并行歸約在單核情況下性能比串行歸約以及手動(dòng)歸約都要差,簡(jiǎn)單說(shuō)就是最差的;
隨著使用核數(shù)的增加,Stream并行效果逐漸變好,多核帶來(lái)的效果明顯。
以上兩個(gè)實(shí)驗(yàn)說(shuō)明,對(duì)于復(fù)雜的歸約操作,Stream串行歸約效果好于手動(dòng)歸約,在多核情況下,并行歸約效果更佳。我們有理由相信,對(duì)于其他復(fù)雜的操作,Stream API也能表現(xiàn)出相似的性能表現(xiàn)。
2.結(jié)論
上述三個(gè)實(shí)驗(yàn)的結(jié)果可以總結(jié)如下:
對(duì)于簡(jiǎn)單操作,比如最簡(jiǎn)單的遍歷,Stream串行API性能明顯差于顯示迭代,但并行的Stream API能夠發(fā)揮多核特性。
對(duì)于復(fù)雜操作,Stream串行API性能可以和手動(dòng)實(shí)現(xiàn)的效果匹敵,在并行執(zhí)行時(shí)Stream API效果遠(yuǎn)超手動(dòng)實(shí)現(xiàn)。
所以,如果出于性能考慮,
1. 對(duì)于簡(jiǎn)單操作推薦使用外部迭代手動(dòng)實(shí)現(xiàn)
2. 對(duì)于復(fù)雜操作,推薦使用Stream API,
3. 在多核情況下,推薦使用并行Stream API來(lái)發(fā)揮多核優(yōu)勢(shì)
4.單核情況下不建議使用并行Stream API
如果出于代碼簡(jiǎn)潔性考慮,使用Stream API能夠?qū)懗龈痰拇a。即使是從性能方面說(shuō),盡可能的使用Stream API也另外一個(gè)優(yōu)勢(shì),那就是只要Java Stream類庫(kù)做了升級(jí)優(yōu)化,代碼不用做任何修改就能享受到升級(jí)帶來(lái)的好處。