http - 同时写入和读取 map 会导致潜在的竞争条件

Question

我有一个非常基本的 Golang 应用程序，它创建并运行一个 HTTP 服务器。服务器有 2 个端点，一个用于发送数据，一个用于接收。

在向服务器发出每个 POST 请求时，解析来自正文的传入数据并将其推送到 channel 。然后我有一个从 channel 读取数据并将数据保存到 map 的函数。

在每次向服务器发出 GET 请求时，JSON 编码 map 并将其发送到客户端。

对 HTTP 服务器的每个请求都是异步运行的，辅助函数在其自己的 goroutine 中同步写入 map 。

基本伪代码如下:

package main

import (
    "net/http"
)

type dataStore map[string]string

func listenHandler(stream chan string) http.HandlerFunc {
    return func(w http.ResponseWriter, r *http.Request) {
        // JSON unmarshal request body

        // push data onto stream
        stream <- data
    }
}

func serveHandler(store *dataStore) http.HandlerFunc {
    return func(w http.ResponseWriter, r *http.Request) {
        // JSON marshal data store
        // serve to client
    }
}

func worker(stream <-chan string) *dataStore {
    store := make(dataStore)
    go func() {
        for data := range stream {
            // process and write data to map
        }
    }()
    return &store
}

func main() {
    stream := make(chan string)
    store := worker(stream)

    http.HandleFunc("/listen", listenHandler(stream))
    http.HandleFunc("/serve", serveHandler(store))

    http.ListenAndServe(":8080", nil)
}

我已经测试并运行了该应用程序，没有出现任何问题，但我被告知它存在潜在的竞争条件，我不确定原因。这是真的？

Answer 1

在给定的代码中，您只是在同步您的写入，而不是您的读取；这意味着您仍然可以在写入 map 的同时从 map 中读取数据，这将是一种竞争条件。

为了使其成为线程安全的，您需要将读取和写入都包装在一个并发结构中 - 使用 channel 或互斥锁 - 以确保在任何给定时间只有一个线程访问它(如果是写入)手术。多个线程可以同时安全地读取，只要没有线程正在写入。 RWMutex 明确提供此功能。