go语言生产者，消费者事例

package main

import "fmt"
import "time"

func main() {

        // ch := make(chan int, 10)
        ch := make(chan int)
        go produce("生产者1",ch)
        go produce("生产者2",ch)

        time.Sleep(1 * time.Second)

        go use(ch)

        time.Sleep(101 * time.Second)
}

func produce(pname string,ch chan int) {
        for i:= 0;i < 20;i++ {
                fmt.Println("produce", pname ," : ", i)
                ch <- i // 这里需要在打印语句之后，否者可能产生理解歧义
                time.Sleep(1 * time.Second)
        }
}

func use(ch chan int) {
        var i int
        loop1:
        i = <-ch
        fmt.Println("use : ",i )
        goto loop1
}

以上代码有很多细节上的不完善的地方，修改：

package main

import "fmt"
import "time"

func main() {

        // ch := make(chan int, 10)
        ch := make(chan int)
        defer close(ch)
        go produce("生产者1",ch)
        go produce("生产者2",ch)

        time.Sleep(1 * time.Second)

        go use(ch)

        time.Sleep(30 * time.Second)
}

func produce(pname string,ch chan int) {
        for i:= 0;i < 20;i++ {
                fmt.Println("produce", pname ," : ", i)
                ch <- i
                time.Sleep(1 * time.Second)
        }
}

func use(ch chan int) {
        for i := range ch {
                fmt.Println("use : ",i )
        }
}

多个生产者，多个消费者

package main

import "fmt"
import "time"

func main() {

        // ch := make(chan int, 10)
        ch := make(chan int)
        defer close(ch)
        go produce("生产者1", ch)
        go produce("生产者2", ch)

        time.Sleep(1 * time.Second)

        go use("消费者1", ch)
        go use("消费者2", ch)
        time.Sleep(30 * time.Second)
}

func produce(pname string, ch chan int) {
        for i := 0; i < 20; i++ {
                fmt.Println("produce", pname, " : ", i)
                ch <- i
                time.Sleep(1 * time.Second)
        }
}

func use(uname string, ch chan int) {
        for i := range ch {
                fmt.Println("use", uname, " : ", i)
        }
}