Question

本主题的最后一小节说明了如何使用专用的goroutine共享数据。尽管，共享内存是线程间彼此通信的传统方法，但 Go 具有内置的同步功能，允许单个 goroutine 拥有共享数据。这意味着其他 goroutines 必须发送消息给这个拥有共享数据的单独 goroutine，这可以防止数据损坏。这样的 goroutine 叫 监视器 goroutine。这 Go 的术语中，这是通过通信来共享而不是通过共享来通信。

该技术通过使用 monitor.go 源文件来说明，分五部分来介绍。monitor.go 程序使用监视器 goroutine 随机产生数字。

monitor.go 的第一部分如下：

package main

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

var readValue = make(chan int)
var writeValue = make(chan int)

readValue 管道用于读取随机数，而 writeValue 管道用于得到新随机数。

monitor.go 的第二段代码如下：

func set(newValue int) {
    writeValue <-newValue
}

func read() int {
    return <-readValue
}

set() 函数的目的是共享变量的值，而 read() 函数的目的是读取已保存变量的值。

monitor.go 程序的第三段代码如下：

func monitor() {
    var value int

    for {
        select {
            case newValue := <-writeValue:
                value = newValue
                fmt.Printf("%d", value)
            case readValue <- value:
        }
    }
}

这个程序的所有逻辑都在这个 monitor() 函数里了。最具体地说，select 语句编排了整个程序的操作。当您有读请求时，read() 函数试图从由 monitor() 函数控制的 readValue 管道读取数据。返回保存在 value 变量中的当前值。另一方面，当您想要修改存储值时，可以调用 set()。往 writeValue 管道写数据也由 select 语句处理。结果就是，不使用 monitor() 函数没人可以处理 value 共享变量。

monitor.go 的第四部分代码如下：

func main() {
    if len(os.Args) != 2 {
        fmt.Println("Please give an integer!")
        return
    }
    n, err := strconv.Atoi(os.Args[1])
    if err != nil {
        fmt.Println(err)
        return
    }

    fmt.Printf("Going to create %d random numbers.\n", n)
    rand.Seed(time.Now().Unix())
    go monitor()

monitor.go 的最后一段代码如下：

    var w sync.WaitGroup
    for r := 0; r < n; r++ {
        w.Add(1)
        go func() {
            defer w.Done()
            set(rand.Intn(10 * n))
        }()
    }
    w.Wait()
    fmt.Printf("\nLast value: %d\n", read())
}

执行 monitor.go 产生如下输出：

$go run monitor.go 20
Going to create 20 random numbers.
89 88 166 42 149 89 20 84 44 178 184 28 52 121 62 91 31c117 140 106
Last value: 106
$go run monitor.go 10
Going to create 10 random numbers.
30 16 66 70 65 45 31 57 62 26
Last value: 26

个人而言，我更喜欢使用监视器 goroutine 而不是传统的共享内存技术，因为使用监视器 goroutine 的实现更安全，更贴合 Go 的哲学思想