lambda 表达式大家在工作中用的多么，小白看了好多遍也理解不住

[wuwudeqi]

[winterbells]

经常用，很简单啊
alt + enter [:doge]

[hantsy]

val filter = {age: Int -> age >30}

[AlisaDestiny]

用，可以简化代码，并且使代码更直观。

[hantsy]

作为 Java 8 特性，lambda 已经出来 5，6 年了吧。你还能以**太新了**为理由拒绝吗?

第一次用的时候，一个项目要上 Java 8 （刚出来不久），要用 Spring Integration 和 Java 8 特性，那时 Spring Integration 4 有一个专门 Java 8 module(现在集成到 core 了), Spring 官方 Blog 有一个介绍 Spring Integration Java 8 DSL。

https://spring.io/blog/2014/11/25/spring-integration-java-dsl-line-by-line-tutorial

能够理解这个 Orders Bean 就差不多了。

@Bean
public IntegrationFlow orders() { // 12
return f -> f // 13
.split(Order.class, Order::getItems) // 14
.channel(c -> c.executor(Executors.newCachedThreadPool()))// 15
.<OrderItem, Boolean>route(OrderItem::isIced, mapping -> mapping // 16
.subFlowMapping("true", sf -> sf // 17
.channel(c -> c.queue(10)) // 18
.publishSubscribeChannel(c -> c // 19
.subscribe(s -> // 20
s.handle(m -> sleepUninterruptibly(1, TimeUnit.SECONDS)))// 21
.subscribe(sub -> sub // 22
.<OrderItem, String>transform(item ->
Thread.currentThread().getName()
+ " prepared cold drink #"
+ this.coldDrinkCounter.incrementAndGet()
+ " for order #" + item.getOrderNumber()
+ ": " + item) // 23
.handle(m -> System.out.println(m.getPayload())))))// 24
.subFlowMapping("false", sf -> sf // 25
.channel(c -> c.queue(10))
.publishSubscribeChannel(c -> c
.subscribe(s ->
s.handle(m -> sleepUninterruptibly(5, TimeUnit.SECONDS)))// 26
.subscribe(sub -> sub
.<OrderItem, String>transform(item ->
Thread.currentThread().getName()
+ " prepared hot drink #"
+ this.hotDrinkCounter.incrementAndGet()
+ " for order #" + item.getOrderNumber()
+ ": " + item)
.handle(m -> System.out.println(m.getPayload()))))))
.<OrderItem, Drink>transform(orderItem ->
new Drink(orderItem.getOrderNumber(),
orderItem.getDrinkType(),
orderItem.isIced(),
orderItem.getShots())) // 27
.aggregate(aggregator -> aggregator // 28
.outputProcessor(group -> // 29
new Delivery(group.getMessages()
.stream()
.map(message -> (Drink) message.getPayload())
.collect(Collectors.toList()))) // 30
.correlationStrategy(m ->
((Drink) m.getPayload()).getOrderNumber()), null) // 31
.handle(CharacterStreamWritingMessageHandler.stdout()); // 32
}

}

[hannhuan]

@l93814690
// 原来的代码
for (Sample s : samples){
if (sample.getValue() == aValue){
System.out.println(sample);
}
}

// 然后...
samples.stream()
.filter(sample -> sample.getValue() == aValue)
.forEach(System.out::println);

// 或者...
List<Sample> sortSampleByIndex = samples.stream()
.sorted((s1, s2) -> s1.getIndex()- s2.getIndex())
.collect(Collectors.toList());


简化下之前写的大概是这样吧_(:з」∠)_ 不过我超菜，这个也不一定是正确的用法

[laminux29]

在 C#中，给学生数组，按照总分、语文分数、其他分数等字段进行多字段排序，自己写的话会有一堆 for 循环以及后处理，而 lambda 只需要一行：

学生数组.OrderBy(x => x.总分).ThenBy(x => x.语文分数).ThenBy....

这玩意本质是函数语言，和 SQL 的思路很像。如果你熟悉 SQL，你就会发现这玩意在处理数据时，非常好用。

[KentY]

@hannhuan 想一下, 如果你在 for 里的调用, 比如那个 out.print(), 如果是另一个会 throw checked exception method, 要怎么处理?

[hantsy]

@hannhuan
.sorted((s1, s2) -> s1.getIndex()- s2.getIndex()) 可以用 Comparator.comparing， 如

.sorted(comparing(Sample::getIndex)

抽取，可以在 Sample 定义

static Comparator<Sample> COMPARAED_BY_INDEX=comparing(Sample::getIndex ）;

应用
.sorted(COMPARAED_BY_INDEX)

[aliveyang]

用 idea 自动补全, 然后就习惯写了

[sagaxu]

最近一年基本没写过 for 循环，你说用的多不多

[hantsy]

@KentY 所有的流式（ Stream，Future，ReactiveStreams ）处理都有异常路径的，让你处理异常。

[rimutuyuan]

完全不用！因为 go 根本没有

[KentY]

@hantsy "异常路径" 是什么? google 没找到对应英语.
缺省的是无法将 exception forward 到外面的. 需要自己 wrap 或者扩展 Consumer, Function 等.
希望我们俩说的是一件事. :D

[hantsy]

@KentY 找到一个 CompletionStage 例子，
https://github.com/hantsy/javaee8-jaxrs-sample/blob/master/backend/src/main/java/com/github/hantsy/ee8sample/aggregate/AggregateResource.java#L105-L112

[hannhuan]

@hantsy 学到了，感谢~下次试试。

[hantsy]

@KentY 留了一个 Exception 路径的入口，怎么优雅处理倒是一个问题，Stackoverflow 很多这种问题。

[ztcaoll222]

记住: 2014 年出的 java 1.8

[KentY]

@hantsy 你的例子是 CompletionStage interface 定义的方法而已. 跟我说的不是一个事. 或许我没表述清, ok:
class Whatever{...
public void foo throw WhateverException(){...}
}

in some method:
...someMethod(Collection<Whatever> collection) throw WhateverException{....
collection.stream().foreach(Whatever::foo); --> here it won't work, the checked exception won't be forwarded to the caller method.
}

我是这个意思

[KentY]

请忽视 syntax mistakes. like throws, (), etc.

[KentY]

@hantsy
"留了一个 Exception 路径的入口" 我不理解这句话. 什么是"路径"? 什么又是"入口"?

另, 我在 SO 也相对活跃. 我不是不知道怎么解决来这求解决方案的. 只是, 看到人们说到 lambda 都是这些 foreach 啊, filter 啊, stream 啊, 没人提到在传统的 for -> stream()这个变换中, 不是所有都可以简单的改写的, 有些情况需要做特殊处理. 仅此而已.