JDK8集合的便捷操作

JDK8新特性，stream相關操作。把集合轉換成stream，再對其進行相關操作，加上lambada表達式。

demo：

List<String> list = Arrays.asList("a","b"); //所有實現了Conllection的類型都可以使用
    	String str = list.stream().map(x->{
    		try {
				return x+" and "+x;
			} catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
				return "";
			}
    	}).collect(Collectors.joining("\n"));  // collect 收集器，把處理過的元素都手機起來，Collectors.joining("\n") 是用"\n"（換行符） 分開，也可以用別自己需要的

System.out.println(str);

　　執行結果：

a and a
b and b

　　集合元素分組收集，用字符串長度進行分組：

    	List<String> list = Arrays.asList("abc","bb","cc","a");
    	Map<Integer, List<String>> collect = list.stream().collect(Collectors.groupingBy(String::length));
    	System.out.println(collect.toString());

　　執行結果：

{1=[a], 2=[bb, cc], 3=[abc]}

　　集合的forEach：

List<String> list1 = Arrays.asList("abc","bb","cc","a");
    	list1.forEach(x->{
    		System.out.println(x.length()); //輸出每個元素的長度
    	});

　　執行結果：

3
2
2
1

max和min函數，返回最值：

    	List<String> list = Arrays.asList("abc","bb","cc","a");
    	Optional<String> max = list.stream().max((a,b)->{
    		return a.compareTo(b);
    	});
    	System.err.println(max.orElse(null));

　　返回的max為list最大值。max可以調用get()函數，但是如果list為空，則max()返回的就是null，那直接使用get就會報錯，但是JDK8改動后，orElse(null)，表示如果對象為空，就返回null，不會報錯。

平行流，就是把集合的個元素開多線程去處理：

List<String> list = IntStream.iterate(1, i -> i + 1).limit(20).mapToObj(Integer::toString).collect(Collectors.toList()); //limit 限制stream的最多個數
        list.stream().parallel().forEach(x->{
            System.out.println(x+" " +Thread.currentThread());
        });
//可以直接用parallelStream轉換平行流，如下

list.parallelStream().forEach(x->{
    System.out.println(x);
});

　　

　　執行結果：

13 Thread[main,5,main]
7 Thread[ForkJoinPool.commonPool-worker-1,5,main]
15 Thread[main,5,main]
6 Thread[ForkJoinPool.commonPool-worker-1,5,main]
9 Thread[ForkJoinPool.commonPool-worker-1,5,main]
10 Thread[ForkJoinPool.commonPool-worker-1,5,main]
8 Thread[ForkJoinPool.commonPool-worker-1,5,main]
2 Thread[ForkJoinPool.commonPool-worker-1,5,main]
1 Thread[ForkJoinPool.commonPool-worker-1,5,main]
5 Thread[ForkJoinPool.commonPool-worker-1,5,main]
4 Thread[ForkJoinPool.commonPool-worker-1,5,main]
18 Thread[ForkJoinPool.commonPool-worker-1,5,main]
20 Thread[ForkJoinPool.commonPool-worker-1,5,main]
19 Thread[ForkJoinPool.commonPool-worker-1,5,main]
17 Thread[ForkJoinPool.commonPool-worker-1,5,main]
16 Thread[ForkJoinPool.commonPool-worker-1,5,main]
12 Thread[ForkJoinPool.commonPool-worker-1,5,main]
11 Thread[ForkJoinPool.commonPool-worker-1,5,main]
14 Thread[main,5,main]
3 Thread[ForkJoinPool.commonPool-worker-3,5,main]

　　parallel執行是使用 ForkJoinPool的線程池，ForkJoinPool的最大線程數是CPU數-1，如果算上當前線程，則會有CPU數量的線程數執行任務。

 

集合的合並，把多個集合合並成一個集合並進行操作：  

        List<String> al = Arrays.asList("a", "b", "c", "d","e","f");
        List<String> al2 = Arrays.asList("a1", "b1", "c1", "d1","e1","f1");
        //吧al和al2合並后按單線程輸出來
        Stream.concat(al.stream(), al2.stream()).forEach(System.out::println);
        System.out.println("******************");
        //把al和al2合並，並按平行流輸出
        Stream.concat(al.stream(),al2.stream()).parallel().forEach(System.out::println);
        System.out.println("------------------");

　　執行結果：

a
b
c
d
e
f
a1
b1
c1
d1
e1
f1
******************
b1
c1
a1
d
f
e
b
c
a
d1
e1
f1
------------------

　　上面一個執行語句是普通流操作，下面一個語句是平行流（parallel）操作。

　　   　　

 

stream還有很多操作

Optional<T> findFirst(); //返回stream的第一個

Optional<T> findAny(); //隨機返回一個

Stream<T> of(T... values) ; //傳入多個