前言
最近一直在看 Kotlin 协程,因为以前也写过 Golang,所以试着去对比了一下,发现了很多好玩的事情。
一个 Kotlin 的小例子
试问下面一段代码,执行结果是什么呢?
fun main() = runBlocking {
//创建自定义线程池
val coroutineDispatcher = Executors.newFixedThreadPool(1).asCoroutineDispatcher()
val name = Thread.currentThread().name
println("main start thread-id = $name")
for (i in 0..2) {
launch(coroutineDispatcher) {
while (true) {
val j = i + 1
val filename = "/Users/xxxx/Desktop/mapping$j.txt"
val file = File(filename)
val contents = file.readText()
val name = Thread.currentThread().name
println("thread-id = $name, do work $i")
}
}
}
println("main end thread-id = $name")
}
这段代码不说 runBlocking 的情况下,启动了3个协程,且执行在一个单线程的线程池中且都是 死循环
,在死循环中读取 mapping.txt(一个大概 30M 的文件)。
我的机器是 Mac
kotlin 的版本号如下:
kotlinx-coroutines-core: 1.4.2
kotlin-stdlib: 1.4.0
结果如下:
main start thread-id = main
main end thread-id = main
thread-id = pool-1-thread-1, do work 0
thread-id = pool-1-thread-1, do work 0
thread-id = pool-1-thread-1, do work 0
thread-id = pool-1-thread-1, do work 0
thread-id = pool-1-thread-1, do work 0
thread-id = pool-1-thread-1, do work 0
thread-id = pool-1-thread-1, do work 0
thread-id = pool-1-thread-1, do work 0
thread-id = pool-1-thread-1, do work 0
thread-id = pool-1-thread-1, do work 0
thread-id = pool-1-thread-1, do work 0
thread-id = pool-1-thread-1, do work 0
// 无限多···
可以看到,协程的载体是 线程
,协程的代码逻辑可以理解为一个 任务
,多线程多任务且没有特殊的阻塞任务(死循环等)的情况下,任务早晚是可以被执行的。
但是这段逻辑是死循环,且是单线程,以致于 i = 0 时,创建的协程任务占用住了当前线程,第二个协程任务 无法被执行
。
所以看得出,对于 Kotlin 的协程任务因为其是 非抢占式
的,是存在不被执行的情况的(协程被 饿死了
)。
一个 Golang 的小例子
试问下面一段代码,执行结果是什么呢?
package main
import (
"fmt"
"io/ioutil"
"os"
"runtime"
"syscall"
"time"
)
func main() {
runtime.GOMAXPROCS(1)
for i := 0; i < 3; i++ {
go func(j int) {
for {
file, err := os.Open(fmt.Sprint("/Users/xxxx/Desktop/mapping", (j + 1), ".txt"))
if err != nil {
panic(err)
}
defer file.Close()
ioutil.ReadAll(file)
tid := gettid()
fmt.Printf("thread-id = %d, do work %d\n", tid, j)
}
}(i)
}
time.Sleep(1 * time.Second)
fmt.Println("finish work")
}
func gettid() (n uint64) {
r0, _, _ := syscall.RawSyscall(syscall.SYS_THREAD_SELFID, 0, 0, 0)
n = uint64(r0)
return n
}
这段代码也很简单,runtime.GOMAXPROCS(1)
设置了 P 只有一个,Golang 中的 go
关键字会启动一个协程
,其余逻辑和 Kotlin 代码的逻辑基本一致,都是启动三个协程读3个文件,那结果跟是不是像 Kotlin 一样,阻塞在第一个任务
呢?
结果如下:
thread-id = 2873233, do work 1
thread-id = 2873233, do work 2
thread-id = 2873233, do work 0
thread-id = 2873233, do work 1
thread-id = 2873233, do work 0
thread-id = 2873233, do work 0
thread-id = 2873233, do work 1
thread-id = 2873233, do work 1
thread-id = 2873233, do work 2
thread-id = 2873233, do work 2
thread-id = 2873233, do work 0
thread-id = 2873233, do work 1
thread-id = 2873233, do work 2
thread-id = 2873233, do work 0
thread-id = 2873233, do work 1
thread-id = 2873233, do work 2
thread-id = 2873233, do work 0
thread-id = 2873233, do work 0
thread-id = 2873233, do work 1
thread-id = 2873233, do work 2
thread-id = 2873233, do work 2
thread-id = 2873233, do work 0
thread-id = 2873233, do work 1
thread-id = 2873233, do work 1
thread-id = 2873233, do work 1
thread-id = 2873233, do work 2
thread-id = 2873233, do work 2
thread-id = 2873233, do work 0
thread-id = 2873233, do work 1
thread-id = 2873233, do work 2
thread-id = 2873233, do work 2
thread-id = 2873233, do work 0
thread-id = 2873233, do work 0
thread-id = 2873233, do work 1
thread-id = 2873233, do work 2
thread-id = 2873233, do work 2
thread-id = 2873233, do work 2
thread-id = 2873233, do work 0
thread-id = 2873233, do work 0
thread-id = 2873233, do work 1
thread-id = 2873233, do work 1
finish work
是不是很神奇!结果 不一致
了!并没有因为死循环卡死在第一个任务上,且在1s后主线程结束、程序退出(因为代码里,主线程只是 sleep 了1s)。
这里就很神奇了,通过 gettid()
打印的线程 id 显示,这3个协程运行在了同一个线程之上,居然可以打破死循环···
gettid 的小插曲
因为电脑是 MacOSX,一开始使用 Golang 自己提供的 syscall.Gettid()
方法来获取 tid,结果发现报错:undefined Gettid()
,似乎是 MacOSX 并没有实现这个方法,所以问了大哥得到了另一种方法
func gettid() (n uint64) {
r0, _, _ := syscall.RawSyscall(syscall.SYS_THREAD_SELFID, 0, 0, 0)
n = uint64(r0)
return n
}
疑问和总结
总结
首先,确认了 Kotlin 的协程似乎并没有任务调度上的优化,只是在线程池中执行任务,存在协程饿死的情况。
其次,Golang 的协程存在一些神奇的优化,即使是死循环,任务也可以交替执行。
疑问
一开始以为是我的 go 版本比较高,因为 go1.14
加入了抢占式调度,我以为是这个的原因。后来发现上面的例子在 go1.13
乃至 go1.10
表现都一致,所以这里的真实原因是什么呢?估计是 netpoller
的作用吧。
有疑问加站长微信联系(非本文作者)