- 等待线程结束 (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
挂起函数。控制线程停止推荐的做法就是采用本例的结束变量方式。