Go语言同步机制的几种常用方法

package main

import (
    "fmt"
    "sync"
)

func main() {
    ch := make(chan bool)
    go worker(ch)
    ch <- true  // 主协程通过发送信号控制worker的开始执行
    fmt.Println("sent true to worker")
}

func worker(ch chan bool) {
    <-ch  // 等待主协程的信号
    fmt.Println("Received true, start working")
}

package main

import (
    "fmt"
    "sync"
    "time"
)

func main() {
    var wg sync.WaitGroup
    wg.Add(2)
    
    go func() {
        defer wg.Done()
        time.Sleep(2 * time.Second)
        fmt.Println("Task 1 completed")
    }()
    
    go func() {
        defer wg.Done()
        fmt.Println("Task 2 completed")
    }()
    
    wg.Wait()
    fmt.Println("All tasks completed")
}

package main

import (
    "fmt"
    "sync"
)

var (
    counter int
    lock    sync.Mutex
)

func main() {
    var wg sync.WaitGroup
    wg.Add(2)

    go updateCounter(&wg)
    go updateCounter(&wg)

    wg.Wait()
    fmt.Printf("Final Counter: %d\n", counter)
}

func updateCounter(wg *sync.WaitGroup) {
    defer wg.Done()
    lock.Lock()
    defer lock.Unlock()
    for i := 0; i < 1000; i++ {
        counter++
    }
}