Kotlin踩坑记

需求:

CompletableFuture的suppayAsync()方法

public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier, Executor executor)

kotlin 写法

val executor = Executors.NewExecutors.newFixedThreadPool(Math.min(shops.size, 100)) { r ->
    val t = Thread(r)
    t.isDaemon = true
    t
}
val priceFutures = shops.stream()
        .map { shop ->
            CompletableFuture.supplyAsync(
                    { "${shop.name} price is ${shop.getPrice(shop.name)}" }, executor)
        }.collect(Collectors.toList())

没错吧, kotlin的lambda就是这么写的啊, 可是报错

image01.png

喷了, 单参数的supplyAsync这样写没有问题的啊,

image02.png

java版本

image03.png

转换

image04.png

image05.png

又喷了, 这和我之前自己写的一模一样啊, 依然报错啊. 放大招, 我强转

image06.png

image07.png

image08.png

可以了, 也可以运行, 但是, 哎哟我擦, 那条黄线什么意思!

image09.png

image10.png