本贴最后更新于 242 天前,其中的信息可能已经东海扬尘

背景

JDK 11 已经快要来了,所以 JDK 的新特征还是要及时学习的。

先从 JDK 8 的特征来入手吧。

本文先记录一下 lambda 表达式的学习。

另外,在 ClickHouse 的学习中,发现 ClickHouse 也支持了 lambda 表达式做为 SQL 的一部分。

所以 lambda 表达式已经是常识了。

lambda 表达式例子

创建线程

public class MainLambda {
	public static void main(String[] args) {
		Thread thread = new Thread(() -> System.out.println("Hello world!"));
		thread.start();
	}
}

输出

Hello world!

排序

public class MainLambda {
	public static void main(String[] args) {
		List<String> list = Arrays.asList(new String[] { "b", "c", "a" });
		Collections.sort(list, (s1, s2) -> s1.compareTo(s2));
		System.out.println(list);
	}
}

输出

[a, b, c]

转换成大写

public class MainLambda {
	public static void main(String[] args) {
		List<String> list = Arrays.asList(new String[] { "b", "c", "a" });
		List<String> newlist = list.stream().map(s -> s.toUpperCase()).collect(Collectors.toList());
		System.out.println(newlist);
	}
}

输出

[B, C, A]

遍历每个元素

import java.util.Arrays;
import java.util.List;

public class MainLambda {
	public static void main(String[] args) {
		List<String> list = Arrays.asList(new String[] { "b", "c", "a" });
		list.stream().forEach(s -> System.out.println(s.toUpperCase()));
	}
}

输出

B
C
A

lambda 表达式语法

一般语法

(Type1 param1, Type2 param2, ..., TypeN paramN) -> {
  statment1;
  statment2;
  //.............
  return statmentM;
}

单参数语法

可以省略前面的小括号

param1 -> {
  statment1;
  statment2;
  //.............
  return statmentM;
}

单语句语法

可以省略后面的大括号, 以及 return 语句。

param1 -> statment

方法引用语法

Class or instance :: method

变量作用域

外部变量在 lambda 表达式引用时,jdk 8 编译器会隐式做为 final 来处理

stream

上面的转换成小写就是一个 stream 的例子。

执行概况

生成

collection.stream()

转换

  • distinct
  • filter
  • map
  • flatMap
  • peak
  • limit
  • skip

汇聚 (Reduce)

collect 方法

示例

public class MainLambda {
	public static void main(String[] args) {
		List<Integer> nums = Lists.newArrayList(1, 1, null, 2, 3, 4, null, 5, 6, 7, 8, 9, 10);
		List<Integer> numsWithoutNull = nums.stream()
				.filter(num -> num != null)
				.collect(
						() -> new ArrayList<Integer>(),
						(list, item) -> list.add(item), 
						(list1, list2) -> list1.addAll(list2)
				);
		System.out.println(numsWithoutNull);
	}
}

结果

[1, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10]

其中 collect 有三个参数

  1. supplier: 生成一个新的实例
  2. accumulator(对象,元素): 把元素加入对象中
  3. combiner(对象, 对象): 合并两个对象

此外,JDK 提供了 Collector 接口,方便来写 collect。这里不多写了。

另外,JDK 预定义了常用的 Collector 接口实现,如 Collectors.toList() 之类。

因此,上面的例子可以写成

public class MainLambda {
	public static void main(String[] args) {
		List<Integer> nums = Lists.newArrayList(1, 1, null, 2, 3, 4, null, 5, 6, 7, 8, 9, 10);
		List<Integer> numsWithoutNull = nums.stream()
				.filter(num -> num != null)
				.collect(Collectors.toList());
		System.out.println(numsWithoutNull);
	}
}

结果

[1, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10]

reduce 方法

示例:求和元素

import com.google.common.collect.Lists;

public class MainLambda {
	public static void main(String[] args) {
		List<Integer> ints = Lists.newArrayList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
		int value = ints.stream()
				.reduce((sum, item) -> sum + item)
				.get();
		System.out.println("ints sum is:" + value);
	}
}

结果

ints sum is:55

其中 reduce 的两个参数,第一个参数 sum 是上一次 reduce 的返回值,第二个参数是本次的元素。所以实际执行过程是: ((( (1+2) + 3 )+ 4) + 5 )

也可以提供一个循环的初始值,如 -1

import java.util.List;

import com.google.common.collect.Lists;

public class MainLambda {
	public static void main(String[] args) {
		List<Integer> ints = Lists.newArrayList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
		int value = ints.stream()
				.reduce(-1, (sum, item) -> sum + item);
		System.out.println("ints sum is:" + value);
	}
}

结果

ints sum is:54

count

示例

import java.util.List;

import com.google.common.collect.Lists;

public class MainLambda {
	public static void main(String[] args) {
		List<Integer> ints = Lists.newArrayList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
		long value = ints.stream().count();
		System.out.println("ints sum is:" + value);
	}
}

结果

ints sum is:10

其它

  • allMatch: 均匹配
  • anyMatch: 有一个匹配
  • findFirst: 返回第一个元素,如果为空则返回 Optional
  • noneMatch: 均不匹配
  • max: 最大值
  • min: 最小值

执行示例

import java.util.List;

import com.google.common.collect.Lists;

public class MainLambda {
	public static void main(String[] args) {
		List<Integer> nums = Lists.newArrayList(1, 1, null, 2, 3, 4, null, 5, 6, 7, 8, 9, 10);
		int sum = nums.stream()
				.filter(num -> num != null)
				.distinct()
				.mapToInt(num -> num * 2)
				.skip(2)
				.limit(4)
				.peek(System.out::println)
				.sum();
		System.out.println("sum is:" + sum);
	}
}

结果: 首先 skip 掉了前 2 个元素,又 limit 了 4 个元素,所以最后剩下了 6,8,10,12 共 4 个元素,其和为 36。

6
8
10
12
sum is:36

并行执行

通过parallelStream,来实现并行执行,默认为 8 个并发。

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.function.Consumer;
import java.util.function.Function;

import org.apache.http.client.fluent.Request;
import org.apache.http.client.fluent.Response;

public class Java8AsyncRequest {
	public static void main(String[] args) {
		List<String> emitters = new ArrayList<String>();
		for (int i = 0; i != 1000; ++i) {
			emitters.add("http://www.abeffect.com/" + i);

		}

		emitters.parallelStream().map(new Function<String, Response>() {
			@Override
			public Response apply(String s) {
				try {
					System.out.println(Thread.currentThread() + ": " + s);
					Thread.sleep(5000L);
					return Request.Get(s).execute();
				} catch (IOException | InterruptedException e) {
					e.printStackTrace();
					return null;
				}
			}
		}).forEach(new Consumer<Response>() {

			@Override
			public void accept(Response response) {
				try {
					System.out.println(response.returnResponse().getStatusLine().getStatusCode());
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		});
	}
}

参考

  • B3log

    B3log 是一个开源组织,名字来源于“Bulletin Board Blog”缩写,目标是将独立博客与论坛结合,形成一种新的网络社区体验,详细请看 B3log 构思。目前 B3log 已经开源了多款产品:PipeSoloSymWide 等,欢迎大家加入,贡献开源。

    2754 引用 • 4351 回帖 • 640 关注
  • Java

    Java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言,是由 Sun Microsystems 公司于 1995 年 5 月推出的。Java 技术具有卓越的通用性、高效性、平台移植性和安全性。

    2111 引用 • 7056 回帖 • 1072 关注
感谢    关注    收藏    赞同    反对    举报    分享