如何在使用指针变量时消除数据竞争

小伙伴们对golang编程感兴趣吗？是否正在学习相关知识点？如果是，那么本文《如何在使用指针变量时消除数据竞争》，就很适合你，本篇文章讲解的知识点主要包括。在之后的文章中也会多多分享相关知识点，希望对大家的知识积累有所帮助！

这里有一些起始代码，

func (chm *concurrentHashMap) nfetchworker() {
    for {
        key := <-nfetchworkerpipe
        chm.mu.rlock()
        data := chm.data[string(key)]
        chm.mu.runlock()
        if data.isusingnfetch {
            chm.mu.lock()
            *(chm.data[string(key)].nfetch)--
            chm.mu.unlock()
        }
    }
}

Go nfetchworker()

struct concurrenthashmap 看起来像这样，

type concurrenthashmap struct {
    data map[string]datablock
    mu sync.rwmutex
}

结构 datablock 看起来像这样，

type datablock struct {
    ...
    nfetch        *int32
    isusingnfetch bool
    ...
}

现在，当我尝试在启用竞赛标志的情况下运行测试时。我明白了，

write at 0x00c00012e310 by goroutine 8:
  (*concurrenthashmap).nfetchworker()

行号指向该行。

*(chm.data[string(key)].nfetch)--

但是，当我不在 datablock.nfetch 中使用指针时，我不会遇到此问题。 但如果我这样做，我就失去了直接从映射对 nfetch 进行更改的能力，而无需将一个全新的结构对象重新分配给映射中的哈希值，这在计算上相对昂贵。我想更改 nfetch 的值，而无需为一个小更改再次重新分配整个结构，同时不受数据争用的影响。有什么解决办法吗？？

对 golang 相当陌生，我可能在这里做了一些非常愚蠢的事情，请随意指出。

更新：添加读写操作功能

func (chm *concurrenthashmap) get(key key) value {
    chm.mu.rlock()
    fetch, ok := chm.data[string(key)]
    chm.mu.runlock()
    if ok {
        if checkvaluevalidity(&fetch) {
            nfetchworkerpipe <- key
            return fetch.value
        } else {
            chm.mu.lock()
            delete(chm.data, string(key))
            chm.mu.unlock()
        }
    }

    return constants.nil
}

写操作

func (chm *ConcurrentHashMap) Insert(key Key, value Value, options Options) {
    ...
    chm.mu.Lock()
    chm.data[string(key)] = Block{
        Value:         value,
        NFetch:        nFetchOld,
        Expiry:        time.Now().Add(delay),
        IsUsingNFetch: foundNFetch,
        IsUsingExpiry: foundTTL,
        mu:            mutex,
    }
    chm.mu.Unlock()
}

正确答案

问题出在 checkvaluevalidity 中，您在其中访问 nfetch 而不锁定它。永远不要在没有锁定指针的情况下访问指针。

func checkvaluevalidity(value *block) bool {
    if value.isusingexpiry && !value.expiry.after(time.now()) {
        return false
    }

    if value.isusingnfetch && *(value.nfetch) <= 0 {
        return false
    }

    return true
}

这段代码应该可以工作

func (chm *ConcurrentHashMap) Get(key Key) Value {
    chm.mu.RLock()
    fetch, ok := chm.data[string(key)]
    isValid := CheckValueValidity(&fetch)
    chm.mu.RUnlock()
    if ok {
        if isValid {
            NFetchWorkerPipe <- key
            return fetch.Value
        } else {
            chm.mu.Lock()
            delete(chm.data, string(key))
            chm.mu.Unlock()
        }
    }

    return constants.NIL
}

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注编程网公众号，一起学习编程~