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 擊中 %dn", 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
}