golang 中带有切片的并发映射

2024年 2月 11日 73.9k 0

golang 中带有切片的并发映射

php小编香蕉带来了一篇精彩的文章,讲述了golang中切片的并发映射。在这篇文章中,我们将了解如何在并发环境中使用切片进行映射操作,并解释了为什么切片在并发编程中非常有用。通过使用golang的并发机制,我们可以在多个goroutine中同时访问和修改切片,从而提高程序的性能和效率。无论你是初学者还是有经验的golang开发者,这篇文章都将给你带来有价值的知识和实践技巧。让我们一起来探索golang中带有切片的并发映射吧!

问题内容

在该领域的一位开发人员几个月前离开后,我一直在尝试解决并发问题,但我找不到解决此问题的适当方法。

对于上下文,我们将客户数据加载到如下结构中:

[ 键 ] -> { 值 }

[客户特定哈希] -> {数据点/文件切片}

示例 - 格式确实很糟糕,抱歉:

[a60d849ad97bfb833e1096941]
->
{
{ StartDate: '01-02-2022', EndDate: '28-02-2022', DataFrames: [1598,921578,12981,21749,192578...]},
{ StartDate: '01-03-2022', EndDate: '28-03-2022', DataFrames: [1234,1567,6781,126978...]},
}

登录后复制

以上是因为我们有 100,000 名客户,并且每天晚上都会启动一个流程,根据每个客户的哈希值(或实际上是一个存储桶)来整合数据。在处理数据帧之前,我们会遍历切片并将数据帧“合并”成一个大的数据帧,其中包含许多法律/会计规则。

它在 goroutine 中运行,以尽快索引所有数据点。

所以实现本质上是一个 sync.Map[string, []DataFrame] 但我注意到虽然映射操作受到保护,但附加到数据帧切片却不受保护。每个哈希值每晚在该切片中可能有大约 20-30 个文件引用。

在过去的两年里,客户数据很有可能被错误地合并,我的任务是修复它。在sync.map之前,他们再次使用了带有Map的RWMutex,但不是切片,它指向本文作为指南。

首先,包含切片的 Map 的想法是适当的数据结构吗?

我尝试创建一个基于 RWMutex 的切片处理程序,但想知道 Map 是否可以有一个 chan DataFrame 来代替在索引客户文件时放入,然后一旦完成,第二步将其合并到一个数组中(如len(chanx)) 会被知道吗?

我主要来自 Java,所以我可能对一些术语感到困惑,所以我很抱歉。

解决方法

您有两个不同的问题:

  • 更新地图时出现并发问题
  • 更新地图条目时出现并发问题
  • sync.Map 将防止 1,但不能防止 2。

    解决这个问题的一种方法是:

    sync.Map[string, *DFrame]

    登录后复制

    哪里

    type DFrame struct {
    sync.RWMutex
    Data []DataFrame
    }

    登录后复制

    一旦从地图中获取条目,您应该 LockRLock 它,然后使用数据。这不仅仅限于切片的附加。即使您只从数据帧中读取,您也必须 RLock 该结构。

    因此,如果您要附加新的数据框:

    df := &DFrame{}
    entry,_:=m.LoadOrStore(key, df)
    dfEntry:=entry.(*DFrame)
    dfEntry.Lock()
    dfEntry.Data=append(dfEntry.Data, newDataFrame)
    dfEntry.Unlock()

    登录后复制

    以上就是golang 中带有切片的并发映射的详细内容,更多请关注每日运维网(www.mryunwei.com)其它相关文章!

    相关文章

    JavaScript2024新功能:Object.groupBy、正则表达式v标志
    PHP trim 函数对多字节字符的使用和限制
    新函数 json_validate() 、randomizer 类扩展…20 个PHP 8.3 新特性全面解析
    使用HTMX为WordPress增效:如何在不使用复杂框架的情况下增强平台功能
    为React 19做准备:WordPress 6.6用户指南
    如何删除WordPress中的所有评论

    发布评论