java8 parallelStream性能測試

本文主要研究下parallelStream的性能。

測試1

@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.NANOSECONDS)
@Warmup(iterations = 5, time = 3, timeUnit = TimeUnit.SECONDS)
@Measurement(iterations = 20, time = 3, timeUnit = TimeUnit.SECONDS)
@Fork(1)
@State(Scope.Benchmark)
public class StreamBenchTest {
    List<String> data = new ArrayList<>();

    @Setup
    public void init() {
        // prepare
        for(int i=0;i<100;i++){
            data.add(UUID.randomUUID().toString());
        }
    }

    @TearDown
    public void destory() {
        // destory
    }

    @Benchmark
    public void benchStream(){
        data.stream().forEach(e -> {
            e.getBytes();
            try {
                Thread.sleep(10);
            } catch (InterruptedException e1) {
                e1.printStackTrace();
            }
        });
    }

    @Benchmark
    public void benchParallelStream(){
        data.parallelStream().forEach(e -> {
            e.getBytes();
            try {
                Thread.sleep(10);
            } catch (InterruptedException e1) {
                e1.printStackTrace();
            }
        });
    }

    public static void main(String[] args) throws RunnerException {
        Options opt = new OptionsBuilder()
                .include(".*" +StreamBenchTest.class.getSimpleName()+ ".*")
                .forks(1)
                .build();
        new Runner(opt).run();
    }

}

parallelStream線程數(shù)

默認是Runtime.getRuntime().availableProcessors() - 1,這里為7

運行結果

# Run complete. Total time: 00:02:44

Benchmark                            Mode  Cnt           Score         Error  Units
StreamBenchTest.benchParallelStream  avgt   20   155868805.437 ± 1509175.840  ns/op
StreamBenchTest.benchStream          avgt   20  1147570372.950 ± 6138494.414  ns/op

測試2

將數(shù)據(jù)data改為30,同時sleep改為100

Benchmark                            Mode  Cnt           Score         Error  Units
StreamBenchTest.benchParallelStream  avgt   20   414230854.631 ±  725294.455  ns/op
StreamBenchTest.benchStream          avgt   20  3107250608.500 ± 4805037.628  ns/op

可以發(fā)現(xiàn)sleep越長吆你,parallelStream優(yōu)勢越明顯。

小結

parallelStream在阻塞場景下優(yōu)勢更明顯,其線程池個數(shù)默認為
Runtime.getRuntime().availableProcessors() - 1燕鸽,如果需修改則需設置-Djava.util.concurrent.ForkJoinPool.common.parallelism=8

doc

?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市啼辣,隨后出現(xiàn)的幾起案子啊研,更是在濱河造成了極大的恐慌,老刑警劉巖鸥拧,帶你破解...
    沈念sama閱讀 218,386評論 6 506
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件党远,死亡現(xiàn)場離奇詭異,居然都是意外死亡富弦,警方通過查閱死者的電腦和手機沟娱,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,142評論 3 394
  • 文/潘曉璐 我一進店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來腕柜,“玉大人济似,你說我怎么就攤上這事矫废。” “怎么了砰蠢?”我有些...
    開封第一講書人閱讀 164,704評論 0 353
  • 文/不壞的土叔 我叫張陵蓖扑,是天一觀的道長。 經(jīng)常有香客問我台舱,道長赵誓,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 58,702評論 1 294
  • 正文 為了忘掉前任柿赊,我火速辦了婚禮俩功,結果婚禮上,老公的妹妹穿的比我還像新娘碰声。我一直安慰自己诡蜓,他們只是感情好,可當我...
    茶點故事閱讀 67,716評論 6 392
  • 文/花漫 我一把揭開白布胰挑。 她就那樣靜靜地躺著蔓罚,像睡著了一般。 火紅的嫁衣襯著肌膚如雪瞻颂。 梳的紋絲不亂的頭發(fā)上豺谈,一...
    開封第一講書人閱讀 51,573評論 1 305
  • 那天,我揣著相機與錄音贡这,去河邊找鬼茬末。 笑死,一個胖子當著我的面吹牛盖矫,可吹牛的內容都是我干的丽惭。 我是一名探鬼主播,決...
    沈念sama閱讀 40,314評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼辈双,長吁一口氣:“原來是場噩夢啊……” “哼责掏!你這毒婦竟也來了?” 一聲冷哼從身側響起湃望,我...
    開封第一講書人閱讀 39,230評論 0 276
  • 序言:老撾萬榮一對情侶失蹤换衬,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后证芭,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體瞳浦,經(jīng)...
    沈念sama閱讀 45,680評論 1 314
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內容為張勛視角 年9月15日...
    茶點故事閱讀 37,873評論 3 336
  • 正文 我和宋清朗相戀三年檩帐,在試婚紗的時候發(fā)現(xiàn)自己被綠了术幔。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 39,991評論 1 348
  • 序言:一個原本活蹦亂跳的男人離奇死亡湃密,死狀恐怖诅挑,靈堂內的尸體忽然破棺而出四敞,到底是詐尸還是另有隱情,我是刑警寧澤拔妥,帶...
    沈念sama閱讀 35,706評論 5 346
  • 正文 年R本政府宣布忿危,位于F島的核電站,受9級特大地震影響没龙,放射性物質發(fā)生泄漏铺厨。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 41,329評論 3 330
  • 文/蒙蒙 一硬纤、第九天 我趴在偏房一處隱蔽的房頂上張望解滓。 院中可真熱鬧,春花似錦筝家、人聲如沸洼裤。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,910評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽腮鞍。三九已至,卻和暖如春莹菱,著一層夾襖步出監(jiān)牢的瞬間移国,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,038評論 1 270
  • 我被黑心中介騙來泰國打工道伟, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留迹缀,地道東北人。 一個月前我還...
    沈念sama閱讀 48,158評論 3 370
  • 正文 我出身青樓皱卓,卻偏偏與公主長得像裹芝,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子娜汁,可洞房花燭夜當晚...
    茶點故事閱讀 44,941評論 2 355

推薦閱讀更多精彩內容

  • 一、多線程 說明下線程的狀態(tài) java中的線程一共有 5 種狀態(tài)兄朋。 NEW:這種情況指的是掐禁,通過 New 關鍵字創(chuàng)...
    Java旅行者閱讀 4,680評論 0 44
  • Java8 in action 沒有共享的可變數(shù)據(jù),將方法和函數(shù)即代碼傳遞給其他方法的能力就是我們平常所說的函數(shù)式...
    鐵牛很鐵閱讀 1,231評論 1 2
  • ForkJoinPool ForkJoinPool 主要用于實現(xiàn)“分而治之”的算法颅和,特別是分治之后遞歸調用的函數(shù)傅事,...
    go4it閱讀 8,376評論 0 0
  • 1. Java基礎部分 基礎部分的順序:基本語法,類相關的語法峡扩,內部類的語法蹭越,繼承相關的語法,異常的語法教届,線程的語...
    子非魚_t_閱讀 31,632評論 18 399
  • http://www.cnblogs.com/angeldevil/p/3801189.html值得一看 Clas...
    snail_knight閱讀 1,423評論 1 0