Golang 使用 select 切换协程
在Go语言中,select关键字用于提供一种方法,可以监听多个通道操作,并且当其中任何一个通道就绪可以进行读写的时候,就会进行对应的读写操作。
下面是一个使用select来切换协程的例子:
package main
import (
"fmt"
"time"
)
func worker(id int, delay time.Duration) <-chan int {
c := make(chan int)
go func() {
time.Sleep(delay * time.Millisecond)
c <- id
}()
return c
}
func main() {
c1 := worker(1, 200*time.Millisecond)
c2 := worker(2, 100*time.Millisecond)
c3 := worker(3, 300*time.Millisecond)
for i := 0; i < 3; i++ {
select {
case r := <-c1:
fmt.Println("worker", r, "executed @", time.Now())
case r := <-c2:
fmt.Println("worker", r, "executed @", time.Now())
case r := <-c3:
fmt.Println("worker", r, "executed @", time.Now())
}
}
fmt.Println("All workers executed @", time.Now())
}
在这个例子中,我们创建了3个worker协程,每个worker协程都有一个对应的通道。然后在main函数中,我们使用select语句来监听这三个通道。当任意一个通道有消息可以读取时,就会执行对应的case语句。这样就实现了协程之间的切换。
这个例子的输出可能像这样:
worker 2 executed @ 2020-04-10 18:52:05.573125 +0000 UTC m=+100.000011185
worker 1 executed @ 2020-04-10 18:52:07.575 +0000 UTC m=+200.000012285
worker 3 executed @ 2020-04-10 18:52:08.575 +0000 UTC m=+300.000012285
All workers executed @ 2020-04-10 18:52:08.575 +0000 UTC m=+300.000012285
这个例子展示了如何使用select语句来控制协程的执行顺序。每个worker协程模拟了一个任务,通过延迟来模拟任务的执行时间,然后通过select语句来决定哪个任务先执行。
评论已关闭