博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Java8-Stream-No.12
阅读量:6593 次
发布时间:2019-06-24

本文共 2678 字,大约阅读时间需要 8 分钟。

import java.util.ArrayList;import java.util.Arrays;import java.util.List;import java.util.UUID;import java.util.concurrent.ForkJoinPool;import java.util.concurrent.TimeUnit;public class Streams12 {
public static void main(String[] args) { List
strings = Arrays.asList("a1", "a2", "b1", "c2", "c1");// test1();// test2(strings); test3(strings);// test4(); } private static void test4() { List
values = new ArrayList<>(100); for (int i = 0; i < 100; i++) { UUID uuid = UUID.randomUUID(); values.add(uuid.toString()); } // sequential long t0 = System.nanoTime(); long count = values .parallelStream() .sorted((s1, s2) -> { System.out.format("sort: %s <> %s [%s]\n", s1, s2, Thread.currentThread().getName()); return s1.compareTo(s2); }) .count(); System.out.println(count); long t1 = System.nanoTime(); long millis = TimeUnit.NANOSECONDS.toMillis(t1 - t0); System.out.println(String.format("parallel sort took: %d ms", millis)); } private static void test3(List
strings) { strings .parallelStream() .filter(s -> { System.out.format("filter: %s [%s]\n", s, Thread.currentThread().getName()); return true; }) .map(s -> { System.out.format("map: %s [%s]\n", s, Thread.currentThread().getName()); return s.toUpperCase(); }) .sorted((s1, s2) -> { System.out.format("sort: %s <> %s [%s]\n", s1, s2, Thread.currentThread().getName()); return s1.compareTo(s2); }) .forEach(s -> System.out.format("forEach: %s [%s]\n", s, Thread.currentThread().getName())); } private static void test2(List
strings) { strings .parallelStream() .filter(s -> { System.out.format("filter: %s [%s]\n", s, Thread.currentThread().getName()); return true; }) .map(s -> { System.out.format("map: %s [%s]\n", s, Thread.currentThread().getName()); return s.toUpperCase(); }) .forEach(s -> System.out.format("forEach: %s [%s]\n", s, Thread.currentThread().getName())); } private static void test1() { // -Djava.util.concurrent.ForkJoinPool.common.parallelism=5 ForkJoinPool commonPool = ForkJoinPool.commonPool(); System.out.println(commonPool.getParallelism()); }}

转载地址:http://rcjio.baihongyu.com/

你可能感兴趣的文章
MyBatis多对多关联查询示例——MyBatis学习笔记之十八
查看>>
ubutun下图片操作
查看>>
修复可执行文件关联
查看>>
Layout属性介绍
查看>>
Swift3.0新变化
查看>>
前端的ejs,less,ant design初探
查看>>
当高德一只脚踏入阿里大门时 就注定另一只脚也会迈进去
查看>>
构建Squid代理服务器
查看>>
css 总结1
查看>>
对Oracle ADF中间件开发的一点感觉
查看>>
AWS EBS Magnetic(standard)磁盘性能测试
查看>>
写一个函数,随机地从大小为n的数组中选取m个整数。要求每个元素被选中的概率相等。...
查看>>
Android 在eclipse中没有出现AVD的解决方法
查看>>
求解立方根
查看>>
Encoding Filters to ensure all data is utf-8
查看>>
docker学习笔记1—常用命令
查看>>
怎样分析一个广告创意
查看>>
CentOS6.6 64位Nginx 安装配置
查看>>
查找出含有特定文件并且24小时内有更新的目录
查看>>
etc、var、proc子目录说明
查看>>