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
想到了IDEA可以将java代码转换成kotlin代码, 妈蛋那我写java版本的转换一下,

java版本

image03.png

转换

image04.png
image05.png

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

image06.png
不报错了.运行一下, 结果:
image07.png
强转也不行啊, 这可咋整.
没办法, 只有写匿名内部类了
image08.png

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

image09.png
再次喷了, 提示我转lambda, 不会还是和之前转的一样吧, 试试
image10.png
哎哟我擦. 要主动构造一个Supplier<String>才可以啊