国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 開發 > Java > 正文

java8中parallelStream性能測試及結果分析

2024-07-13 10:16:13
字體:
來源:轉載
供稿:網友

測試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線程數

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

運行結果

# Run complete. Total time: 00:02:44Benchmark              Mode Cnt      Score     Error UnitsStreamBenchTest.benchParallelStream avgt  20  155868805.437 ± 1509175.840 ns/opStreamBenchTest.benchStream     avgt  20 1147570372.950 ± 6138494.414 ns/op

測試2

將數據data改為30,同時sleep改為100

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

可以發現sleep越長,parallelStream優勢越明顯。

小結

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

以上就是本次講述知識點的全部內容,感謝你對VeVb武林網的支持。


注:相關教程知識閱讀請移步到JAVA教程頻道。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 普格县| 金昌市| 稻城县| 新营市| 丹寨县| 大连市| 宜兴市| 巫溪县| 车险| 五河县| 聂荣县| 靖宇县| 阿拉善盟| 昭平县| 织金县| 吉木萨尔县| 台州市| 西乌珠穆沁旗| 兰西县| 收藏| 通江县| 卓资县| 德令哈市| 綦江县| 大名县| 青岛市| 白玉县| 嘉善县| 民权县| 长沙县| 雷州市| 新野县| 古田县| 琼海市| 清新县| 车险| 嘉荫县| 洪江市| 行唐县| 桐城市| 临泉县|