当前位置: 首页 > news >正文

网站分析报告网络推广优化

网站分析报告,网络推广优化,搜狐网站建设,动漫网站建设答辩ppt一、概念 又叫选择表达式,是一个挂起函数,可以同时等待多个挂起结果,只取用最快恢复的那个值(即多种方式获取数据,哪个更快返回结果就用哪个)。 同时到达 select() 会优先选择先写子表达式,想随…

一、概念

        又叫选择表达式,是一个挂起函数,可以同时等待多个挂起结果,只取用最快恢复的那个值(即多种方式获取数据,哪个更快返回结果就用哪个)。

        同时到达 select() 会优先选择先写子表达式,想随机(公平)的话使用 selectUnbiased() 替换 。

        能被选择的都是 SelectClauseN 函数类型。

public suspend inline fun <R> select(crossinline builder: SelectBuilder<R>.() -> Unit): R 

public sealed interface SelectBuilder<in R> {

        public operator fun SelectClause0.invoke(block: suspend () -> R)
        public operator fun <Q> SelectClause1<Q>.invoke(block: suspend (Q) -> R)
        public operator fun <P, Q> SelectClause2<P, Q>.invoke(param: P, block: suspend (Q) -> R)
        public operator fun <P, Q> SelectClause2<P?, Q>.invoke(block: suspend (Q) -> R): Unit = invoke(null, block)
}

SelectClause0对应事件没有返回值。例如 job.onJoin。
SelectClause1对应事件有返回值。例如 deffered.onAwait 和 channel.onReceive。
SelectClause2对应事件有返回值。此外还需要一个额外的参数,例如 Channel.onSend() 有两个参数,第一个是 Channel 数据类型的值表示即将发送的值,第二个是发送成功时的回调函数。

二、使用

在使用 async() 启动协程的返回类型 Deferred 中,定义了 SelectClause1 函数类型的变量 onAwait,其作用和 await() 一样,只是当其在 select() 中作为子语句时,具有“同时等待看谁最先返回”的效果。同理其它。

2.1 复用多个 job.onJoin

fun main() = runBlocking<Unit> {val job1 = launch {delay(100)println("job 1")}val job2 = launch {delay(10)println("job 2")}select {job1.onJoin { println("job 1 更快") }job2.onJoin { println("job 2 更快") }}delay(1000)
}
//打印:
//job 2
//job 2 更快
//job 1

2.2 复用多个 deffered.onAwait

public interface Deferred<out T> : Job {
        public val onAwait: SelectClause1<T>        //等效await()
fun main() = runBlocking {val defferedCache = async {delay(10)"Cache"}val defferedLocal = async {delay(100)"Local"}val defferedRemote = async {delay(1000)"Remote"}val result = select {defferedCache.onAwait { println("最快的是$it") }defferedLocal.onAwait { println("最快的是$it") }defferedRemote.onAwait { println("最快的是$it") }}delay(2000)println(result) //打印:最快的是Cache
}

2.3 复用多个 channel.onReceive

public interface SendChannel<in E> {

        public val onSend: SelectClause2<E, SendChannel<E>>        //等效send()

}

public interface ReceiveChannel<out E> {

        public val onReceive: SelectClause1<E>        //等效receive()

        public suspend fun receiveCatching(): ChannelResult<E>        //等效receiveCatching()

}

//select() 中的 onReceive() 在已经关闭的通道执行会发生失败,并导致相应的 select() 抛出异常,使用 onReceiveCatching() 在关闭通道时执行特定操作。

suspend fun getDataFromLocal() = withContext(Dispatchers.IO) { "Local" }
suspend fun getDataFromRemote() = withContext(Dispatchers.IO) { "Remote" }@OptIn(ExperimentalCoroutinesApi::class)
fun main() = runBlocking {val produceLocal = produce { send(getDataFromLocal()) }val produceRemote = produce { send(getDataFromRemote()) }val result = select {produceLocal.onReceive { it }produceRemote.onReceive { it }}
//    val result = select {
//        produceLocal.onReceiveCatching { it.getOrNull() ?: "Channel已关闭:produceLocal" }
//        produceRemote.onReceiveCatching { it.getOrNull() ?: "Channel已关闭:produceRemote " }
//    }println("结果更快的是:$result")
}
http://www.hrbkazy.com/news/21288.html

相关文章:

  • 网站佣金怎么做凭证做网站需要多少钱 都包括什么
  • 闲鱼怎么做钓鱼网站厦门百度关键词优化
  • 什么网站可以做期货关键词seo优化
  • 上海免费网站建设模板推荐网红推广
  • 公司网站百度搜索的描述怎么做江门关键词排名工具
  • 外贸出口新三样百度seo在哪里
  • 自考大专报名官网入口seo的搜索排名影响因素有哪些
  • 网站只用css做tab切换黄冈网站推广软件
  • 如何将WORDPRESS主题换成英文seo内部优化方式包括
  • 网络服务提供者知道或者应当知道网络福建企业seo推广
  • 公安网站建设方案书厦门seo网站优化
  • 国外电商网站如何建立bt鹦鹉磁力
  • 福州seo推广优化成都网站优化排名推广
  • wordpress 支付宝重庆seo点击工具
  • 做问卷调查赚钱的网站seo技巧是什么
  • 直播课网站怎样做的查排名的网站
  • 网站建设 课程百度购物平台客服电话
  • 百度网站收录链接提交广东seo网站推广代运营
  • 网站建设指南专业seo站长工具
  • 如何在局域网中做网站百度竞价推广公司
  • 有后台数据的动态网站郑州网站
  • 广西商城网站建设seo流量优化
  • 千助网站建设网站互联网推广
  • 手工制作垃圾桶东莞关键词排名快速优化
  • 有哪些网站做的比较好看什么是友情链接?
  • 关于搜索引擎的搜索技巧seo外链工具
  • 大型网站开发成本网络推广的手段
  • 自己做的网站被封了网站内部seo优化包括
  • 素材下载网站模板开封网站推广
  • 东莞企业推广网站百度竞价排名的优缺点