diff --git a/internal/commentfix/fix_test.go b/internal/commentfix/fix_test.go
index a5cffea..2cf151d 100644
--- a/internal/commentfix/fix_test.go
+++ b/internal/commentfix/fix_test.go
@@ -326,23 +326,17 @@
f, project, db := newFixer(t)
var wg sync.WaitGroup
- wg.Add(1)
- go func() {
+ wg.Go(func() {
runFix(t, f, project, 20)
- wg.Done()
- }()
+ })
- wg.Add(1)
- go func() {
+ wg.Go(func() {
runActions(t, f)
- wg.Done()
- }()
+ })
- wg.Add(1)
- go func() {
+ wg.Go(func() {
runFix(t, f, project, 18)
- wg.Done()
- }()
+ })
wg.Wait()
diff --git a/internal/gcp/firestore/db_test.go b/internal/gcp/firestore/db_test.go
index d9fae12..2124c35 100644
--- a/internal/gcp/firestore/db_test.go
+++ b/internal/gcp/firestore/db_test.go
@@ -175,21 +175,17 @@
var wg sync.WaitGroup
for range 5 {
- wg.Add(1)
- go func() {
+ wg.Go(func() {
db.Lock(name)
time.Sleep(time.Millisecond)
db.Unlock(name)
- wg.Done()
- }()
+ })
- wg.Add(1)
- go func() {
+ wg.Go(func() {
db2.Lock(name)
time.Sleep(time.Millisecond)
db2.Unlock(name)
- wg.Done()
- }()
+ })
}
wg.Wait()
diff --git a/internal/goreviews/collect.go b/internal/goreviews/collect.go
index 1aa8b0d..23aaeea 100644
--- a/internal/goreviews/collect.go
+++ b/internal/goreviews/collect.go
@@ -29,11 +29,9 @@
chAccount := make(chan *gerrit.Change, 16)
var wg sync.WaitGroup
- wg.Add(1)
- go func() {
- defer wg.Done()
+ wg.Go(func() {
collectAccounts(client, accounts, chAccount)
- }()
+ })
// Collect account data first.
for _, project := range projects {
diff --git a/internal/reviews/collect.go b/internal/reviews/collect.go
index 4c08638..82ada1d 100644
--- a/internal/reviews/collect.go
+++ b/internal/reviews/collect.go
@@ -30,9 +30,7 @@
chOut := make(chan ChangePreds, count)
var wg sync.WaitGroup
- wg.Add(1)
- go func() {
- defer wg.Done()
+ wg.Go(func() {
defer close(chIn)
for change := range it {
select {
@@ -41,7 +39,7 @@
return
}
}
- }()
+ })
wg.Add(count)
for range count {
diff --git a/internal/storage/test.go b/internal/storage/test.go
index 8e9ddd8..ad62bc6 100644
--- a/internal/storage/test.go
+++ b/internal/storage/test.go
@@ -139,13 +139,11 @@
db.Lock("abc")
c := make(chan struct{})
var wg sync.WaitGroup
- wg.Add(1)
- go func() {
+ wg.Go(func() {
db.Lock("abc")
close(c)
db.Unlock("abc")
- wg.Done()
- }()
+ })
// The db.Lock in the goroutine should block, since the lock is already held.
select {