Golang语言并行设计的核心goroutine

goroutine实现并发编程，goroutine之间通信使用channel，channel不管是发送数据还是接收数据都是阻塞的，channel默认无缓冲，但也可以指定缓冲大小变成有缓冲，空间有剩余时是无阻塞，直到空间全部用完时才阻塞。

/**
 * goroutine实现并发编程
 * goroutine之间通信使用channel
 * channel不管是发送数据还是接收数据都是阻塞的
 * channel默认无缓冲，但也可以指定缓冲大小变成有缓冲，空间有剩余时是无阻塞，直到空间全部用完时才阻塞
 */
package main

import (
    "fmt"
)

func sum(a []int, c chan int) {
    total := 0
    for _, v := range a {
        total += v
    }
    // 发送total到c
    c <- total
}
func fibonacci(n int, c chan int) {
    x, y := 1, 1
    for i := 0; i < n; i++ {
        // 发送x到c
        c <- x
        x, y = y, x+y
    }
    // 通过内置函数close关闭channel
    close(c)
}
func main() {
    a := []int{9, 2, 6, -5, 3, 0}
    // 使用make创建channel，默认无缓冲，阻塞
    c := make(chan int)
    // 使用 go 关键字启动goroutine
    go sum(a[:len(a)], c)
    go sum(a[len(a)/2:], c)
    // 从c中接收数据
    x, y := <-c, <-c
    fmt.Println(x, y, x+y)
    // 使用make创建有缓冲的channel，空间有剩余时是无阻塞，直到空间全部用完时才阻塞
    // 修改2为1则报错，修改2为3则正常
    c1 := make(chan int, 2)
    c1 <- 1
    c1 <- 2
    fmt.Println(<-c1)
    fmt.Println(<-c1)
    c2 := make(chan int, 10)
    // 使用go关键字启动goroutine
    go fibonacci(cap(c2), c2)
    // 使用range读取channel
    for i := range c2 {
        fmt.Println(i)
    }
}