当前位置：首页 > 文章列表 > Golang > Go问答 > 并发处理中的map、goroutine和mutex的问题

并发处理中的map、goroutine和mutex的问题

来源：stackoverflow 2024-02-15 21:45:27 0浏览收藏

来到golang学习网的大家，相信都是编程学习爱好者，希望在这里学习Golang相关编程知识。下面本篇文章就来带大家聊聊《并发处理中的map、goroutine和mutex的问题》，介绍一下，希望对大家的知识积累有所帮助，助力实战开发！

问题内容

该项目旨在接收 post 路由，这些路由最终将被视为稍后写入数据库的访问权限。直觉是保存与生产中另一个项目的数据库的交互。我决定用 go 来做这件事，但我对这门语言很陌生，而且很难理解。我正在努力做到不丢失或有更多访问。

该项目基本上由一个控制器、一个服务和两个模型组成，足以满足创建它的需求。在我的控制器中，我有负责接收 post 的函数。

controllers/views.go：

func storeviews(c *fiber.ctx) error {
    var songview models.songview
    err := c.bodyparser(&songview)
    if err != nil {
        return c.status(403).json(fiber.map{
            "errors": fiber.map{"request": err.error()},
        })
    }

    songview.date = time.now()

    errs := utils.validatestruct(songview)
    if len(errs) > 0 {
        return c.status(403).json(map[string]interface{}{"errors": errs})
    }

    go services.storeviews(songview)

    return c.sendstatus(fiber.statusok)
}

为了处理接收到的数据，我在服务中创建了这三个函数： services/views.go

var (
    storeviewsmap = make(map[string]*models.songview)
    storecontrol  sync.rwmutex
)

func storeviews(sview models.songview) bool {
    namekey := strconv.itoa(int(sview.songid)) + sview.lang + sview.date.format("2006-01-02")
    songview := getsongview(namekey)
    initsongview(namekey, songview, sview)
    return true
}

func getsongview(name string) *models.songview {
    storecontrol.rlock()
    defer storecontrol.runlock()
    return storeviewsmap[name]
}

func initsongview(name string, songview *models.songview, sview models.songview) bool {
    storecontrol.lock()
    defer storecontrol.unlock()
    if songview == nil {
        insert := models.songview{
            songid: sview.songid,
            lang:   sview.lang,
            date:   sview.date,
            views:  0,
        }
        songviewnew := &insert // see if & is needed
        storeviewsmap[name] = songviewnew
    } else {
        songview.views = songview.views + 1
    }
    return true
}

我尝试实现 rwmutex 以使其在不重叠任何内容的情况下完成所有操作，但它没有按应有的方式工作，有时它会随着视图消失，有时它会错误地拯救 getsongview 函数中的“songview”，以及其他几个问题我发现修改和审查我的代码。当前代码不是我设法接近预期结果的版本，但我没有保存此版本，因此我决定使用当前代码来举例说明我所面临的情况。

我希望您帮助我了解如何处理多个并发请求争议，如何以最佳方式与数据交互，以及如果在使用指针时出现错误，我愿意理解。为了模拟对我的代码的 post“攻击”，我在为此测试制作的另一个 main.go 中使用此代码。

var limit int = 10

func main() {
    channel := make(chan string)
    for i := 0; i < limit; i++ {
        go func(i int) {
            post("http://localhost:3000/views/store", "lang=pt&song_id=296", i)
            channel <- "ok"
        }(i)
        go func(i int) {
            post("http://localhost:3000/views/store", "lang=en&song_id=3016", i)
            channel <- "ok"
        }(i)
        go func(i int) {
            post("http://localhost:3000/views/store", "lang=pt&song_id=3016", i)
            channel <- "ok"
        }(i)
    }
    for i := 0; i < limit*3; i++ {
        <-channel
    }
}

func post(url string, json string, index int) {
    payload := strings.newreader(json)

    client := &http.client{}
    req, err := http.newrequest("post", url, payload)

    if err != nil {
        fmt.println(err)
        return
    }
    req.header.add("content-type", "application/x-www-form-urlencoded")

    res, err := client.do(req)
    if err != nil {
        fmt.println(err)
        return
    }
    defer res.body.close()

    _, err = ioutil.readall(res.body)
    if err != nil {
        fmt.println(err)
        return
    }
    if res.statuscode != 200 {
        fmt.println(res.statuscode)
    }
}

我的歌曲视图模型是这样的：（我只是用它来排序数据，虽然该项目连接到生产中的项目的银行，但它是只读的）

type SongView struct {
    Id       int64     `json:"id"`
    SongId   int64     `json:"song_id" form:"song_id" gorm:"notNull" validate:"required,number"`
    ArtistId int64     `json:"artist_id"`
    Lang     string    `json:"lang" validate:"required,oneof=pt en es de fr"`
    Date     time.Time `json:"date" gorm:"column:created_at" validate:"required"`
    Views    int64     `json:"views"`
}