基本定義：
簡(jiǎn)單理解：lambda表達(dá)式相當(dāng)于創(chuàng)建的一個(gè)匿名對(duì)象.
每個(gè)lambda表達(dá)式都與一個(gè)特定的Java接口相關(guān)聯(lián)，同時(shí)這個(gè)函數(shù)式接口只能包含一個(gè)抽象方法聲明∠危可以在接口上添加@FunctionalInterface注解注明此接口為lambda表達(dá)式相關(guān)接口。
例如：
聲明一個(gè)函數(shù)式接口Converter：
@FunctionalInterface
public interface Converter<F, T> {
T convertor(F from);
// T convertor2(F from);
}
通過lambda表達(dá)式生成一個(gè)Converter類型的對(duì)象：
Converter<String, Integer> converter = (from) -> Integer.valueOf(from);
Integer converted = converter.convertor("8");
System.out.println(converted);
Java8允許通過 :: 關(guān)鍵字傳遞方法或者構(gòu)造函數(shù)的引用。
傳遞靜態(tài)方法
例如：
Converter<String, Integer> staticFunConverter = Integer::valueOf;
Integer staticFunConverted = staticFunConverter.convertor("123");
System.out.println(converted); // 123
傳遞對(duì)象方法
例如：
新建一個(gè)類Something
static class Something {
String startsWith(String s) {
return String.valueOf(s.charAt(0));
}
}
通過:: 關(guān)鍵字引用Something類型對(duì)象的方法：
Something something = new Something();
Converter<String, String> objFunConverter = something::startsWith;
String objFunConverted = objFunConverter.convertor("Java");
System.out.println(objFunConverted);//J
傳遞構(gòu)造方法
先定義一個(gè)多構(gòu)造函數(shù)的bean
static class Person {
String firstName;
String lastName;
Person() {
}
Person(String firstName, String lastName) {
this.firstName = firstName;
this.lastName = lastName;
}
}
然后定義一個(gè)可以創(chuàng)建person 的personFacotory接口
public interface PersonFactory<P extends FuncTest.Person> {
P create(String firstName, String lastName);
}
通過構(gòu)造函數(shù)引用富俄，實(shí)現(xiàn)工廠接口。
PersonFactory<Person> personFactory = Person::new;
Person person = personFactory.create("pee", "hao");
System.out.println(person.lastName);//hao
上面的例子中通過Person::new創(chuàng)建一個(gè)Person類構(gòu)造函數(shù)的引用而咆，Java編譯器會(huì)根據(jù)PersonFactory.create方法的簽名自動(dòng)選擇合適的構(gòu)造函數(shù)霍比。
lambda表達(dá)式訪問變量范圍
lambda表達(dá)式訪問變量范圍和匿名內(nèi)部類相同。
可訪問本地final局部變量暴备。
final int num = 1;
Converter<Integer, String> stringConverter =
(from) -> String.valueOf(from + num);
stringConverter.convert(2); // 3
可訪問成員變量和靜態(tài)變量悠瞬。
lambda表達(dá)式不能訪問默認(rèn)接口方法。
帶有擴(kuò)展方法的接口
public interface Formula {
double calculate(int a);
//JAVA8中可以通過default關(guān)鍵字在接口中添加一個(gè)非抽象方法（即：擴(kuò)展方法)
default double sqrt(int a) {
return Math.sqrt(a);
}
}
Formula formula = new Formula() {
@Override
public double calculate(int a) {
return sqrt(a);
}
};
System.out.println(formula.calculate(9));
System.out.println(formula.sqrt(9));
Formula formula1 = Math::sqrt;//此處無(wú)法通過直接調(diào)用擴(kuò)展方法sqrt實(shí)現(xiàn)涯捻。
Java8內(nèi)置的函數(shù)式接口
已經(jīng)存在的Comparator接口和Runnable接口浅妆。
Predicates（斷言）
Predicates是包含一個(gè)參數(shù)返回值為boolean型的函數(shù)，為了滿足復(fù)雜的邏輯條件(or and negate)Predicates接口包含各種默認(rèn)方法汰瘫。
//Predicates(斷言)
Predicate<String> predicate = (s -> s.length() > 0);
System.out.println(predicate.test("foo"));//true
System.out.println(predicate.negate().test("foo"));//false
Functions
Functions接口接收一個(gè)參數(shù)并生成一個(gè)結(jié)果狂打，可以使用Functions接口的默認(rèn)方法（compose, andThen）將多個(gè)functions串聯(lián)起來(lái)。
注：compose, andThen的區(qū)別混弥，compose方法自身先執(zhí)行趴乡，再把執(zhí)行結(jié)果傳遞給調(diào)用者執(zhí)行。andThen先執(zhí)行前一步的調(diào)用者蝗拿，獲取前一步執(zhí)行結(jié)果后再執(zhí)行晾捏。
//Functions
Function<Integer, Integer> time2 = e -> e * 2;
Function<Integer, Integer> squared = e -> e * e;
System.out.println(time2.compose(squared).apply(4));//32
System.out.println(time2.andThen(squared).apply(4));//64
Consumers
Consumers接口表示在單個(gè)輸入?yún)?shù)上要執(zhí)行的操作。
//Consumers
Consumer<FuncTest.Person> greeter = person -> System.out.println("hello :" + person.firstName);
greeter.accept(new FuncTest.Person("jiahong", "hao"));//hello:jiahong
Comparators
Optionals
Optionals不是一個(gè)函數(shù)式接口哀托，而是一個(gè)用來(lái)防止出現(xiàn)NullPointerException異常的很好工具惦辛。
Streams
java.util.Stream表示可以執(zhí)行一個(gè)或多個(gè)操作的序列元素，stream的操作可以分為兩種類型：中間操作或最終操作仓手。中間操作的返回值還是一個(gè)stream胖齐，最終操作的返回值是一個(gè)確定的類型∷悦埃可以通過鏈?zhǔn)秸{(diào)用可以將多個(gè)中間操作串聯(lián)起來(lái)呀伙。stream上的操作既可以串行執(zhí)行也可以是并行執(zhí)行。
List<String> stringCollection = new ArrayList<>();
stringCollection.add("ddd2");
stringCollection.add("aaa2");
stringCollection.add("bbb1");
stringCollection.add("aaa1");
stringCollection.add("bbb3");
stringCollection.add("ccc");
stringCollection.add("bbb2");
stringCollection.add("ddd1");
Filter
Filter通過斷言來(lái)對(duì)stream中所有的元素進(jìn)行判斷添坊，由于filter是一個(gè)中間操作剿另，因此我們可以在filter后面再調(diào)用forEach操作，F(xiàn)orEach操作接收一個(gè)consumer接口作為參數(shù)，這個(gè)consumer會(huì)在所有通過filter的元素上執(zhí)行雨女。ForEach是一個(gè)最終操作谚攒，返回值類型是void，因此我們不能在ForEach后面再調(diào)用其他操作氛堕。(最終操作是回去執(zhí)行的操作馏臭。這里的forEach相當(dāng)于for(...)循環(huán)了)
stringCollection
.stream()
.filter(s -> s.startsWith("a"))
.forEach(System.out::println);
//aaa2 aaa1
Sorted
Sorted是一個(gè)中間操作，sorted操作接收Comparator接口作為參數(shù)讼稚，返回一個(gè)有序的stream位喂。如果傳遞一個(gè)空函數(shù)給sorted，會(huì)按照自然順序進(jìn)行排序乱灵，如果元素不支持排序，會(huì)在最終操作時(shí)拋出異常七冲。
stringCollection
.stream()
.sorted()
.filter((s) -> s.startsWith("a"))
.forEach(System.out::println);
// aaa1 aaa2
Map
map是一個(gè)中間操作痛倚，通過給定的轉(zhuǎn)換方法map能將stream中的每個(gè)元素映射為另外一種對(duì)象，下面的例子中將每個(gè)string轉(zhuǎn)換為upper-cased string澜躺。map也支持不同類型的映射蝉稳，具體映射的目標(biāo)類型取決于映射方法的返回值類型。
stringCollection
.stream()
.map(String::toUpperCase)
.sorted((a, b) -> b.compareTo(a))
.forEach(System.out::println);
// "DDD2", "DDD1", "CCC", "BBB3", "BBB2", "AAA2", "AAA1"
Match
matching是一個(gè)最終操作掘鄙，返回值類型為boolean型耘戚，可以用來(lái)確定某種斷言是否與stream匹配。
boolean anyStartsWithA =
stringCollection
.stream()
.anyMatch((s) -> s.startsWith("a"));
System.out.println(anyStartsWithA); // true
boolean allStartsWithA =
stringCollection
.stream()
.allMatch((s) -> s.startsWith("a"));
System.out.println(allStartsWithA); // false
boolean noneStartsWithZ =
stringCollection
.stream()
.noneMatch((s) -> s.startsWith("z"));
System.out.println(noneStartsWithZ); // true
Count
Count是一個(gè)最終操作操漠，返回stream中元素的個(gè)數(shù)收津，返回值類型為long。
long startsWithB =
stringCollection
.stream()
.filter((s) -> s.startsWith("b"))
.count();
System.out.println(startsWithB); // 3
Reduce
Reduce是一個(gè)最終操作浊伙，通過給定的方法在stream上執(zhí)行reduce操作撞秋，返回值為使用Optional接口包裝的reduce值。(Reduce含義：把...歸納為,減少)
Optional<String> reduced =
stringCollection
.stream()
.sorted()
.reduce((s1, s2) -> s1 + "#" + s2);
reduced.ifPresent(System.out::println);
// "aaa1#aaa2#bbb1#bbb2#bbb3#ccc#ddd1#ddd2"
Parallel Streams
Parallel Streams能在多個(gè)線程上并發(fā)地執(zhí)行嚣鄙，下面的例子中通過簡(jiǎn)單的使用parallel streams就能大幅度地提高系統(tǒng)性能吻贿。
首先我們創(chuàng)建一個(gè)很大的元素唯一的list.
int max = 1000000;
List<String> values = new ArrayList<>(max);
for (int i = 0; i < max; i++) {
UUID uuid = UUID.randomUUID();
values.add(uuid.toString());
}
我們開始測(cè)試在這個(gè)stream上執(zhí)行排序所需的時(shí)間
Sequential Sort
long t0 = System.nanoTime();
long count = values.stream().sorted().count();
System.out.println(count);
long t1 = System.nanoTime();
long millis = TimeUnit.NANOSECONDS.toMillis(t1 - t0);
System.out.println(String.format("sequential sort took: %d ms", millis));
// sequential sort took: 899 ms
Parallel Sort
long t0 = System.nanoTime();
long count = values.parallelStream().sorted().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));
// parallel sort took: 472 ms
上面的兩段代碼幾乎相同，但是parallel sort的速度幾乎比sequential Sort速度快50%哑子。
Map
Map<Integer, String> map = new HashMap<>();
for (int i = 0; i < 10; i++) {
//當(dāng)鍵值在map中不存在時(shí),才會(huì)執(zhí)行put操作.
map.putIfAbsent(i, "val" + i);
}
map.forEach((key, value) -> System.out.println(value));
map.computeIfPresent(3, (num, val) -> val + num + 1);
System.out.println(map.get(3)); // val331 函數(shù)式接口返回值與原來(lái)的value不同,則賦予新值.
map.computeIfPresent(9, (num, val) -> null);
System.out.println(map.containsKey(9));//false 函數(shù)式接口返回值為null,則相應(yīng)的mapping會(huì)被刪除
//當(dāng)鍵值在map中不存在時(shí),才會(huì)計(jì)算函數(shù)式接口的值,并設(shè)值.
map.computeIfAbsent(23, num -> "val" + num);
System.out.println(map.containsKey(23));
System.out.println(map.get(23));
map.computeIfAbsent(3, num -> null);
System.out.println(map.get(3));//val331
map.computeIfAbsent(3, num -> "bam");
System.out.println(map.get(3));//val331
下面的例子展示了map如何刪除value不為空的key的操作舅列。
map.remove(3, "val3");
map.get(3); // val33
map.remove(3, "val33");
map.get(3); // null
Another helpful method:
System.out.println(map.getOrDefault(42, "not found")); // not found
System.out.println(map.get(42));//null
//Merging entries of a map is quite easy:
map.merge(9, "val9", (value, newValue) -> value.concat(newValue));
map.get(9); // val9
map.merge(9, "concat", (value, newValue) -> value.concat(newValue));
map.get(9); // val9concat
merge方法在key不存在時(shí)，可以向map中添加key/value卧蜓，當(dāng)key存在時(shí)帐要，可以對(duì)這個(gè)key對(duì)應(yīng)的value執(zhí)行merge操作。
todo:stream()方法中的collect()需要總結(jié)下烦却，涉及到了經(jīng)常要用到的list裝換map
JAVA8 教程
Java8 lambda表達(dá)式10個(gè)示例
【譯】Java 8的新特性—終極版(杜琪)
Java8初體驗(yàn)（二）Stream語(yǔ)法詳解
Java8 新特性之流式數(shù)據(jù)處理
