qbit/go
1
0
Fork 0
mirror of https://github.com/golang/go synced 2024-11-24 02:50:11 -07:00
Code Releases Activity

internal: convert calls to atomic type

Browse Source 
For #53821

Change-Id: Iee8ccea714726bbb6a4b384887bb107c29b823a9
GitHub-Last-Rev: 119aad3624
GitHub-Pull-Request: golang/go#54862
Reviewed-on: https://go-review.googlesource.com/c/go/+/428335
TryBot-Result: Gopher Robot <gobot@golang.org>
Run-TryBot: Bryan Mills <bcmills@google.com>
Auto-Submit: Bryan Mills <bcmills@google.com>
Reviewed-by: Bryan Mills <bcmills@google.com>
Reviewed-by: Keith Randall <khr@google.com>
This commit is contained in:
cui fliter 2022-09-04 14:55:00 +00:00 committed by Gopher Robot
parent a50c434308
commit cdc6aeb673
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/internal/singleflight/singleflight_test.go
View File

@ -44,9 +44,9 @@ func TestDoDupSuppress(t *testing.T) {
var g Group
var wg1, wg2 sync.WaitGroup
c := make(chan string, 1)
var calls int32
var calls atomic.Int32
fn := func() (any, error) {
if atomic.AddInt32(&calls, 1) == 1 {
if calls.Add(1) == 1 {
// First invocation.
wg1.Done()
}
@ -81,7 +81,7 @@ func TestDoDupSuppress(t *testing.T) {
// least reached the line before the Do.
c <- "bar"
wg2.Wait()
if got := atomic.LoadInt32(&calls); got <= 0 || got >= n {
if got := calls.Load(); got <= 0 || got >= n {
t.Errorf("number of calls = %d; want over 0 and less than %d", got, n)
}
}