啟動了兩個goroutine,並完成一些工作。在各自迴圈的每次迭代之後,在goroutine 會使用LoadInt64 來檢查shutdown 變數的值。這個函數會安全地返回shutdown 變數的一個副本。如果這個副本的值為1,goroutine 就會跳出迴圈並終止。 ...
啟動了兩個goroutine,並完成一些工作。在各自迴圈的每次迭代之後,在goroutine 會使用LoadInt64 來檢查shutdown 變數的值。這個函數會安全地返回
shutdown 變數的一個副本。如果這個副本的值為1,goroutine 就會跳出迴圈並終止。
package main import ( "fmt" "sync" "sync/atomic" "time" ) var ( //通知正在執行的goroutine停止工作的標誌 shutdown int64 //計數信號量 wg sync.WaitGroup ) func main() { //計數加2,等待兩個goroutine wg.Add(2) //創建兩個goroutine go doWork("A") go doWork("B") //主groutine睡眠1秒 time.Sleep(1 * time.Second) fmt.Println("主:立刻關閉") //安全的賦值全局變數 atomic.StoreInt64(&shutdown, 1) //主goroutine等待子goroutine結束 wg.Wait() } //模擬執行工作的goroutine //檢測主goroutine設定的值shutdown來決定是否提前終止 func doWork(name string) { defer wg.Done() for { fmt.Printf("%s 工作 \r\n", name) //子goroutine睡眠250毫秒 time.Sleep(250 * time.Millisecond) //子goroutine讀取全局變數 if atomic.LoadInt64(&shutdown) == 1 { //停止 fmt.Printf("關閉 %s \r\n", name) break } } }