Kotlin线程(4)线程管理
- 等待线程结束 (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 函数，不推荐使用这个函数，这个函数有时会引发严重的系统故障，类似的还有 suspend 和 resume 挂起函数。控制线程停止推荐的做法就是采用本例的结束变量方式。
