Go并发模型学习

Go concurrency model ：原文地址：

http://www.oschina.net/translate/go-concurrency-patterns-pipelines?print

特性：原子并发特性

优势：Golang可有效的使用I/O和多CPU特性。

1 什么是管道

在Golang对于管道没有明确的定义；它只是许多种并发程序中的一种。管道是通道连接的一系列阶段， 每个阶段是一组goroutine运行相同的功能。在每个阶段，goroutine运行步骤为：

• 从上游经过入境通道接受值

• 对数据执行一些功能操作，通常会产生新的值

• 从下游经过出境通道发送值

举个例子：

第一阶段：gen，以从列表读出整数的方式转换整数列表到一个通道。gen函数开始goroutine后， 在通道上发送整数并且在在所有的值被发送完后将通道关闭：

func gen(nums ...int) <-chan int {

    out := make(chan int)

    go func() {

        for _,n := range nums {

            out <- n

        }

        close(out)

    }()

    return out

}

func sq(in <-chan int) <-chan int {

    out := make(chan int)

    go func() {

        for n := range in {

            out <- n * n

       }

        close(out)
08
    }()

    return out

}

func main() {

    // Set up the pipeline.

    c := gen(2,3)

    out := sq(c)
 
    // Consume the output.

    fmt.Println(<-out) // 4

    fmt.Println(<-out) // 9

扇出（fan-out）：多个函数能从相同的通道中读数据，直到通道关闭；这提供了一种在一组“人员”中分发任务的方式，使得CPU和I/O的并行处理.

扇入（fan-in）：一个函数能从多个输入中读取并处理数据，而这多个输入通道映射到一个单通道，该单通道随着所有输入的结束而关闭。

管道函数模型：

• 当所有的发送操作结束后， 阶段关闭他们的出境通道。

• 阶段持续接收来自入境通道的值，直到那些通道关闭。

这个模型允许每一个接收阶段通过range循环的写数据，确保一旦所有向下游发送的值发送成功，所有的goroutine退出。

但在一个真实的管道上，阶段并不总是接收所有的入境值。有时设计是这样的：接收者可能只需要一个子集值就能取得进展。更多时候是一个阶段早早的退出，因为一个入境值代表一个早期阶段的错误。在这两种情况下接收者不应该等待剩余的值到达，我们想要早期阶段停止产生后续阶段不需要的值。

显式取消

下面列出了构建管道的指南：

• 状态会在所有发送操作做完后，关闭它们的流出 channel

• 状态会持续接收从流入 channel 输入的数值，直到 channel 关闭或者其发送者被释放。

管道要么保证足够能存下所有发送数据的缓冲区，要么接收来自接收者明确的要放弃 channel 的信号，来保证释放发送者。

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!