Golangchannel通信实现教程

func main() {
    ch := make(chan string)
<pre class="brush:php;toolbar:false;">go func() {
    ch <- "Hello from goroutine"
}()

msg := <-ch
fmt.Println(msg)

}

func main() {
    ch := make(chan int, 3) // 缓冲大小为3
<pre class="brush:php;toolbar:false;">ch <- 1
ch <- 2
ch <- 3

close(ch)

for num := range ch {
    fmt.Println(num)
}

}

func producer(id int, ch chanfunc main() {
ch := make(chan int)
var wg sync.WaitGroup<pre class="brush:php;toolbar:false;">for i := 0; i < 3; i++ {
    wg.Add(1)
    go producer(i, ch, &wg)
}

go func() {
    wg.Wait()
    close(ch)
}()

for num := range ch {
    fmt.Println("Received:", num)
}

}

func main() {
    ch1 := make(chan string)
    ch2 := make(chan string)
<pre class="brush:php;toolbar:false;">go func() { ch1 <- "data from ch1" }()
go func() { ch2 <- "data from ch2" }()

for i := 0; i < 2; i++ {
    select {
    case msg1 := <-ch1:
        fmt.Println(msg1)
    case msg2 := <-ch2:
        fmt.Println(msg2)
    }
}

}