go处理线程之间的交互示例代码

package main
import (
    "fmt"
    "time"
)
func main() {
    // 创建一个 channel
    ch := make(chan string)
    // 启动一个 goroutine
    go func() {
        time.Sleep(1 * time.Second) // 模拟一些工作
        ch <- "Hello from goroutine!" // 发送数据到 channel
    }()
    // 主 goroutine 等待并接收数据
    msg := <-ch
    fmt.Println(msg)
}

package main
import (
    "fmt"
    "sync"
)
func main() {
    var wg sync.WaitGroup
    for i := 0; i < 3; i++ {
        wg.Add(1) // 增加计数
        go func(i int) {
            defer wg.Done() // 减少计数
            fmt.Printf("Goroutine %d\n", i)
        }(i)
    }
    wg.Wait() // 等待所有 goroutine 完成
    fmt.Println("All goroutines finished!")
}

package main
import (
    "fmt"
    "sync"
)
var (
    counter int
    mu      sync.Mutex
)
func increment(wg *sync.WaitGroup) {
    defer wg.Done()
    mu.Lock()         // 加锁
    counter++         // 访问共享数据
    mu.Unlock()       // 解锁
}
func main() {
    var wg sync.WaitGroup
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go increment(&wg)
    }
    wg.Wait()
    fmt.Println("Final counter:", counter)
}

package main
import (
    "fmt"
    "time"
)
func main() {
    ch1 := make(chan string)
    ch2 := make(chan string)
    go func() {
        time.Sleep(2 * time.Second)
        ch1 <- "Message from channel 1"
    }()
    go func() {
        time.Sleep(1 * time.Second)
        ch2 <- "Message from channel 2"
    }()
    select {
    case msg1 := <-ch1:
        fmt.Println(msg1)
    case msg2 := <-ch2:
        fmt.Println(msg2)
    }
}