Kotlin(十九)协程初探究<1>

Kotlin 的Coroutine

前面说过传统web框架Tomcat采用的多线程方式,当请求接入服务器时,Tomcat会为每个请求链接分配一个线程。当请求不是很多的时候,系统不会出现问题,请求数目超过最大分配线程数,这个时候会有多个线程阻塞住,会出现一些问题。

多线程在执行的时候,知识看上去是同时执行,因为线程执行是通过cpu来进行调度的,cpu通过在每个线程之间来回切换,使其看上去是同时执行的一样。其实cpu在某个时间片内只能执行一个线程,当这个线程执行一会它就会去执行其他线程。当cpu从一个线程切换到另一个线程时候会执行如下操作:

  • 保存当前执行线程的执行上下文
  • 载入另一个线程的执行上下文

协程是一个无优先级的调度组件,允许子程序在特定地方挂起恢复。
线程包含于进程,协程包含于线程。
只要内存够用,一个线程中可以有任意多个协程,但某一时刻只能由一个协程运行,多个协程该线程分配到的计算机资源。

fun main(args: Array<String>) {
    GlobalScope.launch { // 在后台启动一个协程
        delay(1000L) // 延迟一秒(非阻塞)
        println("World!") // 延迟之后输出
    }
    println("Hello,") // 协程被延迟了一秒,但是主线程继续执行
    Thread.sleep(2000L) // 为了使JVM保活,阻塞主线程2秒钟(这段代码删掉会出现什么情况???)
}

launch 构造了一个协程,该协程内部调用了delay方法,该方法会挂起协程,但是不会阻塞线程,所以在协程推迟1s的时间,线程中的“Hello”会先输出,然后“World!”才会输出

协程的切换可以通过程序自己控制,是工作在线程之上的,不需要操作系统调度,理论上降低了开销。

1. launch 与 runBlocking

上面的例子只是为了说明线程和协程理论的相似处,存在不合理的地方。我们既使用了delay方法,又使用了sleep方法。

  • delay 只能在协程中使用,用于挂起协程,不会阻塞线程。
  • sleep 用来阻塞线程
fun main(args: Array<String>) = runBlocking{
    launch { // 在后台启动一个协程
        delay(1000L) // 延迟一秒(非阻塞)
        println("World!") // 延迟之后输出
    }
    println("Hello,") // 协程被延迟了一秒,但是主线程继续执行
    Thread.sleep(2000L) // 为了使JVM保活,阻塞主线程2秒钟(这段代码删掉会出现什么情况???)
}

这个例子和上面的基本没有变化,结果也一样,我们看到两个函数
launch和runBlocking 这两个函数都会启动一个协程,不同的是runBlocking启动一个主协程,launch启动的协程能在runBlocking中运行(反过来不行)。runBlocking 方法仍旧会阻塞当前执行的线程。

2. 协程的生命周期与join

delay和sleep都是延迟执行,目的都是保活程序。
但是我们执行IO操作的时候并不知道操作执行多久,没法设定一个时间让程序保活,为了让协程执行完毕前一直保活,我们可以使用join

fun main(args: Array<String>) = runBlocking {
    val job = launch {
        search()
    }
    println("Hello,")
    job.join()
}

suspend fun search() {
    delay(1000L)
    println("World!")
}

出现了一个新的关键词suspend。用suspend的方法,和其他方法没有大的区别,不同的是suspend方法内部还可以调用其他suspend修饰的方法,只能在协程内部或其他suspend方法中执行,普通方法则不行。delay就是一个suspend修饰的方法。

fun main(args: Array<String>) = runBlocking<Unit> {
    val one = searchItemlOne()
    val two = searchItemTwo()
    println("The items is ${one} and ${two}")
}

fun main(args: Array<String>) = runBlocking<Unit> {
    val one = async { searchItemlOne() }
    val two = async { searchItemTwo() }
    println("The items is ${one.await()} and ${two.await()}")
}

再看下上面的例子,执行结果是一样的,第一个在协程内部执行是顺序的,类似java中的同步,限执行searchItemlOne在执行searchItemTwo。为了让两个方法并行执行,使用Kotlin中的async与await。async类似前面的launch都是创建了一个子协程,不同的是async有返回值,返回Deferred对象。

Deferred 是一个非阻塞可以取消的future,是一个带有结果的job
launch 也会返回一个job对象,但是没有返回值

我们还用到了await,future是非阻塞,意思将来会有一个结果返回。await可以等待这个值查询到后,将它获取出来。

fun main() = runBlocking{
    val time = measureTimeMillis {
        val one = searchItemlOne()
        val two = searchItemTwo()
        println("The items is ${one} and ${two}")
    }
    println("Cost time is ${time} ms")
}

The items is item-one and item-two
Cost time is 2034 ms

再看并行

fun main(args: Array<String>) = runBlocking{
    val time = measureTimeMillis {
        val one = async { searchItemlOne() }
        val two = async { searchItemTwo() }
        println("The items is ${one.await()} and ${two.await()}")
    }

    println("Cost time is ${time} ms")
}

The items is item-one and item-two
Cost time is 1170 ms

从理论代码看不出差别,但是从时间打印来看,并行效果就明显了。

©著作权归作者所有,转载或内容合作请联系作者
禁止转载,如需转载请通过简信或评论联系作者。
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,951评论 6 497
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,606评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,601评论 0 350
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,478评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,565评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,587评论 1 293
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,590评论 3 414
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,337评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,785评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,096评论 2 330
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,273评论 1 344
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,935评论 5 339
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,578评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,199评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,440评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,163评论 2 366
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,133评论 2 352

推荐阅读更多精彩内容