select在1.6的版本中还是一个实验性的特性但是如果select与Deferred、Channel结合使用的话可以显著的提高程序运行的效率以及改善程序的灵活性和可扩展性。今天主要来聊一聊select的使用。1.select就是选择「更快」的结果举个例子现在要获取用户信息进行展示有缓存获取和网络请求获取两种方式正常情况下缓存获取是最快的但是信息不一定是最新的网络获取比前者慢但是确实最新的他们的代码逻辑可以这么写fun main() runBlocking { val startTime System.currentTimeMillis() val cacheUserInfo getCacheUserInfo(张三) updateUI(cacheUserInfo) println(cache 耗时${(System.currentTimeMillis() - startTime)}) val networkUserInfo getNetworkUserInfo(李四) updateUI(networkUserInfo) println(network 耗时${(System.currentTimeMillis() - startTime)}) } /** * 从缓存获取用户信息 */ suspend fun getCacheUserInfo(name: String): User { delay(1000) return User(name, 20) } /** * 从网络获取用户信息 */ suspend fun getNetworkUserInfo(name: String): User { delay(1500) return User(name, 44) } fun updateUI(user: User) { println(${user.name}${user.age}) } data class User( val name: String, val age: Int ) //输出结果 //张三20 //cache 耗时1011 //李四44 //network 耗时2515上面代码流程是先从缓存中获取信息再从网络连接中获取信息主要分为四步第一步查询缓存信息第二步缓存服务返回信息更新 UI第三步查询网络服务第四步网络服务返回信息更新 UI。但是上面这段代码是建立在缓存获取信息没有问题或者比网络请求快的前提下假如说这里的缓存出现了超时的问题那么网络请求的函数是无法被执行的因为getCacheUserInfo是一个挂起函数它在没有被恢复的时候后面的函数是无法被执行的这里假设缓存出现了超时情况将getCacheUserInfo函数中的delay(1000)改为delay(2000)那输出的结果如下//输出结果 //张三20 //cache 耗时2005 //李四44 //network 耗时3511看的出来networkUserInfo最终获取到的时间也会被延长那么如果将getCacheUserInfo()和getNetworkUserInfo()两个函数的执行改为并行的话即使缓存出现问题用户信息也是可以正常获取的只不过走的是网络请求fun main() runBlocking { val startTime System.currentTimeMillis() val cacheDeffered async { val cacheUserInfo getCacheUserInfo(张三) updateUI(cacheUserInfo) println(cache 耗时${(System.currentTimeMillis() - startTime)}) } val networkDeffered async { val networkUserInfo getNetworkUserInfo(李四) updateUI(networkUserInfo) println(network 耗时${(System.currentTimeMillis() - startTime)}) } } //输出结果 //李四44 //network 耗时1595 //张三20 //cache 耗时2085从结果看的出来并行之后不存在getNetworkUserInfo被阻塞的情况那么如果我想要的是这两种方式谁最先返回就用谁的数据呢要怎么实现这里就进入倒了今天的主体select。2.select和async用select将上面async实现并行的代码进行改造fun main() runBlocking { val startTime System.currentTimeMillis() val userInfo selectUser { async { getCacheUserInfo(张三) } .onAwait { it } //这里是重点 async { getNetworkUserInfo(李四) } .onAwait { it } //这里是重点 } if(userInfo!null){ updateUI(userInfo) println(select 耗时${(System.currentTimeMillis() - startTime)}) } }这里首先使用select这个高阶函数包裹了两次查询的服务同时传入了泛型参数 User代表我们要选择的数据类型是 User然后在async后面添加了onAwait { it }这里的目的是为了将结果传递给selectselect才能将结果返回给变量并在后面更新UI。至于它的输出结果其实就是根据谁先有响应就输出谁的结果比如说缓存获取时间为delay(1000)网络请求时间为delay(1500)得到的结果就是缓存的响应反过来的话得到的结果就是网络请求的响应所以select的作用就是选择最快有响应的哪一个结果进行输出这样就避免了等待太长的时间得到糟糕的体验。这里还存在一个问题就是如果缓存获取不出现问题那么缓存的获取是一定会比网络请求快的用了select之后每次获取到的信息都是旧的了这里要怎么解决解决这个问题其实就是加一个标识这里我贴上完整代码/** * 从缓存获取用户信息 */ suspend fun getCacheUserInfo(name: String): User { delay(1000) return User(name, 20) } /** * 从网络获取用户信息 */ suspend fun getNetworkUserInfo(name: String): User { delay(1500) return User(name, 44) } fun updateUI(user: User) { println(${user.name}${user.age}) } data class User( val name: String, val age: Int, val isCache: Boolean false ) fun main() runBlocking { val startTime System.currentTimeMillis() val cacheUserInfo async { getCacheUserInfo(张三) } val networkUserInfo async { getNetworkUserInfo(李四) } val userInfo selectUser { cacheUserInfo.onAwait { it?.copy(isCache true) } networkUserInfo.onAwait { it?.copy(isCache false) } } if (userInfo ! null) { updateUI(userInfo) println(select 耗时${(System.currentTimeMillis() - startTime)}) } if (userInfo ! null userInfo.isCache) { val network networkUserInfo.await()?: returnrunBlocking updateUI(network) println(network 耗时: ${System.currentTimeMillis() - startTime}) } } //输出结果 //张三20 //select 耗时1057 //李四44 //network 耗时: 1571通过isCache这个标识当获取的是缓存数据时要再进行网络数据的请求这样缓存中的数据就是重视最新的了。3.select和channel前面在channel使用篇讲过channel可以发送多条数据假设这里有这样一个需求后台下发一个任务每执行一步都要先在屏幕上展示再写入本地文件(这两件事可以做成一件这里主要为了举例)只用channel来实现的话大概是这样fun main() runBlocking { val startTime System.currentTimeMillis() val channelUI produce { send(UI展示任务启动) delay(100) send(UI展示任务执行) delay(100) send(UI展示任务终止) delay(100) } val channelFile produce { send(写入文件任务启动) delay(100) send(写入文件任务执行) delay(100) send(写入文件任务终止) delay(100) } channelUI.consumeEach{ println(it) } channelFile.consumeEach{ println(it) } println(耗时: ${System.currentTimeMillis() - startTime}) } //输出结果 //UI展示任务启动 //UI展示任务执行 //UI展示任务终止 //写入文件任务启动 //写入文件任务执行 //写入文件任务终止 //耗时: 686从输出结果可以看到好像是实现这个需求但是写入文件的操作是在UI展示完成后才开始执行那么加入UI展示有很多呢是不是就意味着写入文件这一操作什么时候执行也不知道了。如果用select实现会是怎么样的结果呢fun main() runBlocking { val startTime System.currentTimeMillis() val channelUI produce { send(UI展示任务启动) delay(100) send(UI展示任务执行) delay(100) send(UI展示任务终止) delay(100) } val channelFile produce { send(写入文件任务启动) delay(100) send(写入文件任务执行) delay(100) send(写入文件任务终止) delay(100) } //1 repeat(6) { selectChannel(channelUI, channelFile) } println(耗时: ${System.currentTimeMillis() - startTime}) } suspend fun selectChannel( channelUI: ReceiveChannelString, channelFile: ReceiveChannelString ):String selectString{ //2 channelUI.onReceive{ it.also { println(it) } } channelFile.onReceive{ it.also { println(it) } } } //输出结果 //UI展示任务启动 //写入文件任务启动 //UI展示任务执行 //写入文件任务执行 //UI展示任务终止 //写入文件任务终止 //耗时: 400先对上面的几个注释进行说明注释1执行6次链各个管道中各有3条数据执行6次的主要目的是将管道中的数据全部消耗掉注释2onReceive{}是Channel在select当中的语法当Channel当中有数据以后它就会被回调通过这个 Lambda我们也可以将结果传出去前后两种方式的执行结果对比可以发现select的实现比Channel的实现耗费的时间更少并且他们是交替执行的。那么此时如果channelUI遇到问题了channelFile是否会执行呢fun main() runBlocking { val startTime System.currentTimeMillis() val channelUI produceString { delay(100000) } val channelFile produce { send(写入文件任务启动) delay(100) send(写入文件任务执行) delay(100) send(写入文件任务终止) delay(100) } repeat(6) { selectChannel(channelUI, channelFile) } println(耗时: ${System.currentTimeMillis() - startTime}) } suspend fun selectChannel(channelUI: ReceiveChannelString, channelFile: ReceiveChannelString):String selectString{ channelUI.onReceive{ it.also { println(it) } } channelFile.onReceive{ it.also { println(it) } } } //输出结果 //写入文件任务启动 //写入文件任务执行 //写入文件任务终止 //Exception in thread main kotlinx.coroutines.channels.ClosedReceiveChannelException: Channel was closed可以看到这里正常的输出了channelFile的数据这说明select加入后即使另一个管道没有数据也不会影响整个任务的执行。在输出结果的同时还爆出了一个错误这个错误的原因是channel中只有三个数据当他们发送完毕后就被关闭了而第4次调用时因为channel已经被关闭了所以爆出了这个错误如果把【6】改成【3】这个错误就不会出现了。但是在这个需求中并不知道具体有多少数据那要解决这个问题就要使用onReceiveCatching{}了。fun main() runBlocking { val startTime System.currentTimeMillis() val channelUI produceString { delay(100000) } val channelFile produce { send(写入文件任务启动) delay(100) send(写入文件任务执行) delay(100) send(写入文件任务终止) delay(100) } repeat(6) { val result selectChannel(channelUI, channelFile) //打印结果 println(result) } println(耗时: ${System.currentTimeMillis() - startTime}) } suspend fun selectChannel(channelUI: ReceiveChannelString, channelFile: ReceiveChannelString):String selectString{ //这里做了改动 channelUI.onReceiveCatching{ it.getOrNull() ?: channelUI is closed! } channelFile.onReceiveCatching{it.getOrNull() ?: channelFile is closed! } } //输出结果 //写入文件任务启动 //写入文件任务执行 //写入文件任务终止 //channelFile is closed! //channelFile is closed! //channelFile is closed! //耗时: 442这时候即使不知道管道里有多少个数据我们也不用担心崩溃的问题了。在onReceiveCatching{}这个高阶函数当中我们可以使用it.getOrNull()来获取管道里的数据如果获取的结果是 null就代表管道已经被关闭了。不过上面的代码仍然还有一个问题那就是得到所有结果以后程序不会立即退出因为我们的channelUI一直在 delay()。这时候完成 6 次repeat()调用以后将channelUI、channelFile取消即可。//在repeat()后添加即可 channelUI.cancel() channelFile.cancel()4.select和channel、Deffered之间的联系通过前面的分析可以发现当select加入后它们原本的 API 会多一个 on 前缀。所以只要记住了 Deferred、Channel 的 API你是不需要额外记忆 select 的 API 的只需要在原本的 API 的前面加上一个 on 就行了。另外还要注意的是当 select 与 Deferred 结合使用的时候当并行的 Deferred 比较多的时候你往往需要在得到一个最快的结果以后去取消其他的 Deferred。比如说对于 Deferred1、Deferred2、Deferred3、Deferred4、Deferred5其中 Deferred2 返回的结果最快这时候我们往往会希望取消其他的 Deferred以节省资源。那么在这个时候我们可以使用类似这样的方式fun main() runBlocking { suspend fun T fastest(vararg deferreds: DeferredT): T select { fun cancelAll() deferreds.forEach { it.cancel() } for (deferred in deferreds) { deferred.onAwait { cancelAll() it } } } val deferred1 async { delay(100L) println(done1) // 没机会执行 result1 } val deferred2 async { delay(50L) println(done2) result2 } val deferred3 async { delay(10000L) println(done3) // 没机会执行 result3 } val deferred4 async { delay(2000L) println(done4) // 没机会执行 result4 } val deferred5 async { delay(14000L) println(done5) // 没机会执行 result5 } val result fastest(deferred1, deferred2, deferred3, deferred4, deferred5) println(result) } /* 输出结果 done2 result2 */5.总结select就是选择“更快的结果”。当 select 与 async、Channel 搭配以后可以并发执行协程任务以此大大提升程序的执行效率甚至用户体验并且还可以改善程序的扩展性、灵活性。关于 select 的 API不需要去刻意记忆只需要在 Deferred、Channel 的 API 基础上加上 on 这个前缀即可。作者无糖可乐爱好者链接https://juejin.cn/post/7181792189532831801最后如果想要成为架构师或想突破20~30K薪资范畴那就不要局限在编码业务要会选型、扩展提升编程思维。此外良好的职业规划也很重要学习的习惯很重要但是最重要的还是要能持之以恒任何不能坚持落实的计划都是空谈。如果你没有方向这里给大家分享一套由阿里高级架构师编写的《Android八大模块进阶笔记》帮大家将杂乱、零散、碎片化的知识进行体系化的整理让大家系统而高效地掌握Android开发的各个知识点。相对于我们平时看的碎片化内容这份笔记的知识点更系统化更容易理解和记忆是严格按照知识体系编排的。全套视频资料一、面试合集二、源码解析合集三、开源框架合集欢迎大家一键三连支持若需要文中资料直接点击文末CSDN官方认证微信卡片免费领取↓↓↓