同时写入和读取地图会导致潜在的竞争条件

Question

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

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

根据对服务器的每个 GET 请求，JSON 编组映射并将其发送给客户端。

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

基本伪代码如下：

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

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

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

同时写入和读取地图会导致潜在的竞争条件

Concurrently writing and reading from map causes potential race condition

concurrency

http

go

race-condition