在所有 goroutine bing 发出后,如何使用 goroutine 按顺序打印数字?
这是随机打印数字的代码:
func main() {
var wg sync.WaitGroup
wg.Add(10)
for i := 1; i <= 10; i++ {
go func(i int) {
defer wg.Done()
fmt.Printf("i = %d\n", i)
}(i)
}
wg.Wait()
发出 goroutine 以打印如下所示的数字,这不是我想要的解决方案。
func main() {
var wg sync.WaitGroup
for i := 1; i <= 10; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()
fmt.Printf("i = %d\n", i)
}(i)
wg.Wait()
}
我希望发出所有 goroutine,然后让它们按顺序打印数字。
func main() {
wg.Add(10)
count := 10
cBegins := make([]chan interface{}, count)
for i := range cBegins {
cBegins[i] = make(chan interface{})
}
go func() {
cBegins[0] <- struct {}{}
}()
for i := 0; i < count; i++ {
go func(i int) {
defer wg.Done()
<-cBegins[i]
fmt.Printf("i = %d\n", i)
if i < 9 {
cBegins[i+1] <- struct {}{}
}
}(i)
}
wg.Wait()
}
只需添加
runtime.Gosched()
即可打印之前声明的 goroutine。这是可行的,因为 runtime.Gosched()
允许你运行其他 goroutine。在循环的每次迭代中,只有 2 个 goroutine:主 goroutine 和带有 fmt.Printf
的匿名 goroutine。
func main() {
var wg sync.WaitGroup
for i := 1; i <= 10; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()
fmt.Printf("i = %d\n", i)
}(i)
runtime.Gosched()
}
wg.Wait()
}