美文网首页
Kotlin线程(4)线程管理

Kotlin线程(4)线程管理

作者: 狼性代码人 | 来源:发表于2019-06-19 08:49 被阅读0次
  • 等待线程结束 (join)
  • 线程让步 (yield)
  • 线程停止

一、等待线程结束

  当一个线程调用其它线程(t1)的 join 函数时,便会使当前线程进入阻塞状态。如果这个其它线程(t1)结束 或 等待超时,则当前线程回到就绪状态。

Thread 类提供了多个版本的 join函数:

  • join()。等待该线程结束。
  • join(millis: Long)。等待该线程结束的时间最长为 millis(单位: 毫秒)。如果超时为 0,意味着要一直等待下去。

示例1代码如下:

var value = 0

fun main(args: Array<String>?) {
    println("主线程 main 函数开始...")
    val t1 = thread {
        println("子线程开始...")
        for (i in 0..1) {
            println("子线程执行...")
            value++
        }
        println("子线程结束...")
    }

    // 主程序被阻塞,等待t1线程执行结束
    t1.join()
    println("value = $value")
    println("主线程 main 函数结束...")
}

示例1运行结果:

I: 主线程 main 函数开始...
I: 子线程开始...
I: 子线程执行...
I: 子线程执行...
I: 子线程结束...
I: value = 2
I: 主线程 main 函数结束...

  使用 join() 阻塞线程,等待子线程 t1 结束,再执行主线程。

示例2代码如下:

fun main(args: Array<String>?) {
    println("主线程 main 函数开始...")
    val t1 = thread {
        println("子线程开始...")
        for (i in 0..1) {
            println("子线程执行...")
            sleep(1000)
            value++
        }
        println("子线程结束...")
    }

    // 主程序被阻塞,等待t1线程执行结束
    t1.join(1000)
    println("value = $value")
    println("主线程 main 函数结束...")
}

示例2运行结果:

I: 主线程 main 函数开始...
I: 子线程开始...
I: 子线程执行...
I: value = 0
I: 主线程 main 函数结束...
I: 子线程执行...
I: 子线程结束...

  使用 join(millis: Long) 阻塞线程,原本应该等待子线程 t1 结束,再执行主线程;但实际由于超时,主线程提前执行完毕。

  提示:使用 join 函数的场景是一个线程依赖于另外一个线程的运行结果,所以调用另一个线程的 join 函数直到它运行完成。

二、线程让步

  线程类Thread还提供了一个yield函数,调用yield函数能够使当前线程给其他线程让步。它类似于sleep函数,能够使运行状态的线程放弃 CPU 使用权,暂停片刻,然后重新回到就绪状态。sleep 函数是让线程进行休眠,给其他线程运行的机会,无论线程优先级高低都有机会运行,yield 函数只给相同优先级 或 更高优先级线程机会

示例代码如下:

fun run(isYield: Boolean = true) {
    for (i in 1..10) {
        println("第${i}次执行 - ${currentThread().name}")
        yield()
    }
    println("执行完成!${currentThread().name}")
}

fun main(args: Array<String>?) {
    thread { run(false) }
    thread(name = "测试yield线程") { run(true) }
}

  提示:yield 函数只能给相同优先级 或 更高优先级的线程让步,yield 函数在实际开发中很少使用,大多数使用 sleep 函数。sleep 函数可以控制时间,而 yield 函数不能。

三、线程停止

  线程体结束后,线程进入死亡状态,线程就停止了。但是有些业务比较复杂,如想开发一个下载程序,每个一段时间执行一次下载任务,下载任务一般会由子线程休眠一段时间再执行。这个下载在子线程中会有一个死循环,但是为了能够停止子线程,要设置一个结束变量。

代码示例如下:

var command = ""

fun main(args: Array<String>?) {
    val t1 = thread {
        while (command != "exit") {
            println("下载中...")
            sleep(5000)
        }
        println("任务执行完成!")
    }
    command = readLine()!! // 接收从键盘输入的字符串
}

运行结果:

下载中...
下载中...
下载中...
exit
任务执行完成!

Process finished with exit code 0

  提示:控制程序停止不要使用 Thread 提供的 stop 函数,不推荐使用这个函数,这个函数有时会引发严重的系统故障,类似的还有 suspendresume 挂起函数。控制线程停止推荐的做法就是采用本例的结束变量方式。

相关文章

  • Kotlin线程(4)线程管理

    等待线程结束 (join)线程让步 (yield)线程停止 一、等待线程结束   当一个线程调用其它线程(t1)的...

  • 多线程-线程池

    1.什么是线程池 (1)管理线程的池子(2)管理线程,避免新增线程和销毁线程的资源消耗(3)提高响应速度(4)重复...

  • Kotlin-Coroutine协程初探-扫盲

    什么是协程? 轻量级线程, 用户态的, 很像线程但又不是线程。 什么是kotlin中的协程? 协程是Kotlin官...

  • kotlin 协程

    协程是轻量级的线程。 kotlin协程是kotlin的扩展库(kotlinx.coroutines)。 线程在An...

  • kotlin 单利模式

    1. 懒汉式 java线程不安全 缺点是在多线程不能正常工作 线程安全 效率比较低 kotlin线程不安全 线程...

  • Kotlin 单例

    1.懒汉模式 java kotlin 2.懒加载(非线程安全) java kotlin 3.懒加载(线程安全) j...

  • 线程池设计

    线程池管理器(CustomThreadPool): 用于创建并管理线程池工作线程(CustomWorker):线程...

  • android协程

    Kotlin的协程,本质上是一个线程框架,它可以方便的切换线程的上下文(如主线程切换到子线程/子线程切回主线程)。...

  • Kotlin 协程中,关于 runBlocking, launc

    引入大佬的话,Kotlin的协程,本质上是一个线程框架,它可以方便的切换线程的上下文(如主线程切换到子线程/子线程...

  • kotlin 线程切换工具

    这里先不说协程,前面讲过java线程池,kotlin扩展函数。 java 线程池Executorskotlin 扩...

网友评论

      本文标题:Kotlin线程(4)线程管理

      本文链接:https://www.haomeiwen.com/subject/djczfctx.html