用生产者消费者理解golang channel

zengfan · · 2047 次点击 · · 开始浏览

这是一个创建于的文章，其中的信息可能已经有所发展或是发生改变。

golang实现多生产者多消费者：

package main

import (
    "fmt"
    "time"
)

func consumer(cname string, ch chan int) {
    for i := range ch {
        fmt.Println("consumer--", cname, ":", i)
    }
    fmt.Println("ch closed.")
}

func producer(pname string, ch chan int) {
    for i := 0; i < 4; i++ {

        fmt.Println("producer--", pname, ":", i)
        ch <- i
    }
}

func main() {
    //用channel来传递"产品", 不再需要自己去加锁维护一个全局的阻塞队列
    data := make(chan int)
    go producer("生产者1", data)
    go producer("生产者2", data)
    go consumer("消费者1", data)
    go consumer("消费者2", data)

    time.Sleep(10 * time.Second)
    close(data)
    time.Sleep(10 * time.Second)
}

运行结果：

D:/Go/pv/pv.exe  [D:/Go/pv]
producer-- 生产者2 : 0
producer-- 生产者2 : 1
producer-- 生产者2 : 2
producer-- 生产者1 : 0
consumer-- 消费者2 : 1
consumer-- 消费者2 : 2
consumer-- 消费者2 : 0
producer-- 生产者1 : 1
producer-- 生产者1 : 2
consumer-- 消费者2 : 1
consumer-- 消费者2 : 2
producer-- 生产者1 : 3
consumer-- 消费者2 : 3
consumer-- 消费者1 : 0
producer-- 生产者2 : 3
consumer-- 消费者2 : 3
ch closed.
ch closed.
成功: 进程退出代码 0.

可以看出，用golang实现生产者消费者非常简单，PV操作不需要各种加锁解锁，奥妙就在于CSP模型，即golang提倡的用通信代替共享内存。

有疑问加站长微信联系（非本文作者）