传递的值不会立即被视为已被接收

你在学习Golang相关的知识吗？本文《传递的值不会立即被视为已被接收》，主要介绍的内容就涉及到，如果你想提升自己的开发能力，就不要错过这篇文章，大家要知道编程理论基础和实战操作都是不可或缺的哦！

下面的代码启动了一些工作人员。每个工作人员通过通道接收一个值，该值被添加到映射中，其中键是工作人员 id，值是收到的数字。最后，当我添加收到的所有值时，我应该得到预期结果（在本例中为 55，因为这是从 1..10 添加时得到的结果）。在大多数情况下，我没有看到预期的输出。我在这里做错了什么？我不想通过添加睡眠来解决它。我想以编程方式识别问题并修复它。

type counter struct {
  value int
  count int
}

var data map[string]counter
var lock sync.Mutex

func adder(wid string, n int) {
  defer lock.Unlock()
  lock.Lock()
  d := data[wid]
  d.count++
  d.value += n
  data[wid] = d

  return
}

func main() {
  fmt.Println(os.Getpid())
  data = make(map[string]counter)
  c := make(chan int)
  for w := 1; w <= 3; w++ {  //starting 3 workers here
    go func(wid string) {
      data[wid] = counter{}
      for {
        v, k := <-c
        if !k {
          continue
        }
        adder(wid, v)
      }
    }(strconv.Itoa(w))  // worker is given an ID 
  }
  time.Sleep(1 * time.Second) // If this is not added, only one goroutine is recorded.
  for i := 1; i <= 10; i++ {
    c <- i
  }
  close(c)
  total := 0
  for i, v := range data {
    fmt.Println(i, v)
    total += v.value
  }
  fmt.Println(total)
}

解决方案

您的代码有两个重要的竞争：

• data[wid] = counter{} 的初始化与其他可能正在读取和重写 data 的 goroutine 不同步。
• 工作协程在完成修改 data 时不会发出信号，这意味着您的主协程可能会在完成写入之前读取 data 。

你还有一个奇怪的结构：

for {
    v, k := <-c
    if !k {
        continue
    }
    adder(wid, v)
}

k 仅当通道 c 关闭时才会为 false，之后 goroutine 会尽可能旋转。最好写成 for v := range c。

为了修复主 goroutine 中的读取代码，我们将使用更正常的 for ... range c 习惯用法并添加 sync.waitgroup，并让每个工作线程在等待组上调用 done() 。然后主 goroutine 将等待它们完成。为了修复初始化，我们将锁定映射（还有其他方法可以做到这一点，例如，在启动任何 goroutine 之前设置映射，或者依赖于空映射这一事实槽读为零，但这很简单）。我还拿出了额外的调试。结果是 this code，也可以在 go 演示中找到。

package main

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

type counter struct {
    value int
    count int
}

var data map[string]counter
var lock sync.Mutex
var wg sync.WaitGroup

func adder(wid string, n int) {
    defer lock.Unlock()
    lock.Lock()
    d := data[wid]
    d.count++
    d.value += n
    data[wid] = d
}

func main() {
    // fmt.Println(os.Getpid())
    data = make(map[string]counter)
    c := make(chan int)
    for w := 1; w <= 3; w++ { //starting 3 workers here
        wg.Add(1)
        go func(wid string) {
            lock.Lock()
            data[wid] = counter{}
            lock.Unlock()
            for v := range c {
                adder(wid, v)
            }
            wg.Done()
        }(strconv.Itoa(w)) // worker is given an ID
    }
    for i := 1; i <= 10; i++ {
        c <- i
    }
    close(c)
    wg.Wait()
    total := 0
    for i, v := range data {
        fmt.Println(i, v)
        total += v.value
    }
    fmt.Println(total)
}

（这可以很容易地改进，例如，wg 没有理由是全局的。）

本篇关于《传递的值不会立即被视为已被接收》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！