Go语言无缓冲通道

// 无缓冲的整型通道
unbuffered := make(chan int)
// 有缓冲的字符串通道
buffered := make(chan string, 10)

// 有缓冲的字符串通道
buffered := make(chan string, 10)
// 通过通道发送一个字符串
buffered <- "Gopher"
// 从通道接收一个字符串
value := <-buffered

package ChannelDemo

import (
　　"fmt"
　　"math/rand"
　　"sync"
　　"time"
)

var wg sync.WaitGroup

func init() {
    rand.Seed(time.Now().UnixNano())
}

func PlayTennis() {
    court := make(chan int)
    wg.Add(2)
    //启动了两个协程，一个纳达尔一个德约科维奇
    go player("纳达尔", court)
    go player("德约科维奇", court)

    //将1放到通道中，模拟开球
    court <- 1
    wg.Wait()
}

func player(name string, court chan int) {
    defer wg.Done()
    for {
        // 将数据从通道中取出
        ball, ok := <-court
        if !ok {
            fmt.Printf("选手 %s 胜利\n", name)
            return
        }

        //获取一个随机值，如果可以整除13，就让一个人没有击中，进而关闭整个通道
        n := rand.Intn(100)
        if n%13 == 0 {
            fmt.Printf("选手 %s 没接到\n", name)
            close(court)
            return
        }
        //如果击中球，就将击球的数量+1，放回通道中
        fmt.Printf("选手 %s 击中 %d\n", name, ball)
        ball++
        court <- ball
    }
}

package ChannelDemo

import (
    "fmt"
    "sync"
    "time"
)

var runnerWg sync.WaitGroup

func Running() {
    //创建一个“接力棒”，也就是通道
    baton := make(chan int)
    runnerWg.Add(1)
    //创建第一个跑步走
    go Runner(baton)
    //开始跑
    baton <- 1
    runnerWg.Wait()
}

func Runner(baton chan int) {
    var newRunner int

    //选手接过接力棒
    runner := <-baton
    fmt.Printf("第 %d 选手接棒 \n", runner)

    //如果不是第四名选手，那么说明比赛还在继续
    if runner != 4 {
        //创建一名新选手
        newRunner = runner + 1
        fmt.Printf("第 %d 准备接棒 \n", newRunner)
        go Runner(baton)
    }

    //模拟跑步
    time.Sleep(100 * time.Millisecond)
    //如果第四名跑完了，就结束
    if runner == 4 {
        fmt.Printf("第 %d 结束赛跑 \n", runner)
        runnerWg.Done()
        return
    }

    fmt.Printf("第 %d 选手和第 %d 选手交换了接力棒 \n",
        runner,
        newRunner)

    //选手递出接力棒
    baton <- newRunner
}