数据竞争或糟糕设计：二者取其一？

本篇文章主要是结合我之前面试的各种经历和实战开发中遇到的问题解决经验整理的，希望这篇《数据竞争或糟糕设计：二者取其一？》对你有很大帮助！欢迎收藏，分享给更多的需要的朋友学习~

我正在实现一个集成第三方 api 的应用程序，该 api 每秒的点击次数有限制。我编写了我的适配器，直到我使用竞争条件检测器运行测试之前，我是一个快乐的人。

设计很简单，有一个：

• 计算其发出的请求的结构
• 每秒将此计数器重置为 0 的勾号
• 此结构上的私有函数，在满足条件以允许对 api 进行额外调用之前一直处于阻塞状态。

运行此测试用例效果非常好，直到您为其指定 -race 标志。 我相信数据争用是由tick线程尝试重置命中计数器以及增加它的调用请求引起的......

我的设计是否糟糕，或者我应该忍受数据争用警报吗？

import (
    "sync"
    "testing"
    "time"
)

var subject httpClientWrapper

func init() {
    subject = httpClientWrapper{
        hits:       0,
        hitsSecond: 1,
    }
    // reset hits every second to 0
    go func() {
        tick := time.Tick(1 * time.Second)
        for range tick {
            subject.hits = 0
        }
    }()
}

type httpClientWrapper struct {
    hits, hitsSecond int
}

var m sync.Mutex

func (c *httpClientWrapper) allowCall() {
    m.Lock()
    callAllowanceReached := c.hits >= c.hitsSecond
    for callAllowanceReached {
        // cool down for one second
        time.Sleep(1 * time.Second)
        callAllowanceReached = c.hits >= c.hitsSecond
    }
    c.hits = c.hits + 1
    m.Unlock()
}

func TestItSleeps(t *testing.T) {
    timeStart := time.Now()
    var wg = sync.WaitGroup{}
    for i := 0; i < 3; i++ {
        wg.Add(1)
        go func() {
            subject.allowCall()
            wg.Done()
        }()
    }
    wg.Wait()
    elapsedTime := time.Since(timeStart)
    if elapsedTime < (1 * time.Second) {
        t.Errorf("this test should not had been able to run in less than a second due to locks and cool down")
    }
}

解决方案

对 .hits 的任何访问都应该位于互斥体后面，因此

// reset hits every second to 0
go func() {
    tick := time.tick(1 * time.second)
    for range tick {
        m.lock()
        subject.hits = 0
        m.unlock()
    }
}()

此外，互斥体锁定时不应发生任何睡眠，因此

m.Lock()
...
    {
        m.Unlock()
        // cool down for one second
        time.Sleep(1 * time.Second)
        m.Lock()
        ...
    }
...
m.Unlock()

以上就是《数据竞争或糟糕设计：二者取其一？》的详细内容，更多关于的资料请关注golang学习网公众号！