使用context关闭协程以及协程中的协程

时间:2023-03-09 23:13:40
使用context关闭协程以及协程中的协程
package main

import (
"sync"
"context"
"fmt"
"time"
) var wg sync.WaitGroup func worker2(ctx context.Context) {
LOOP:
for {
fmt.Printf("worker2\n")
time.Sleep(time.Second)
select {
case <- ctx.Done():
break LOOP
default:
}
}
} func worker(ctx context.Context) {
go worker2(ctx)
LOOP:
for {
fmt.Printf("worker\n")
time.Sleep(time.Second)
select {
case <- ctx.Done():
break LOOP
default: }
}
wg.Done()
} func main() {
ctx := context.Background()
ctx, cancel := context.WithCancel(ctx)
wg.Add(1)
go worker(ctx)
//time.Sleep(time.Second*3)
cancel()
wg.Wait()
}