国产探花免费观看_亚洲丰满少妇自慰呻吟_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教程頻道。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 寻甸| 仙居县| 绥中县| 陵水| 鄂尔多斯市| 兴和县| 沧州市| 新平| 铜陵市| 柳江县| 留坝县| 白沙| 隆回县| 沁阳市| 团风县| 松溪县| 蒙城县| 麻栗坡县| 师宗县| 荣成市| 怀安县| 调兵山市| 鄂州市| 伊宁县| 白沙| 石河子市| 青龙| 涞水县| 江川县| 会昌县| 柏乡县| 武宣县| 余江县| 洛隆县| 商城县| 响水县| 蓬安县| 和顺县| 阿拉善左旗| 上思县| 天全县|