diff options
Diffstat (limited to 'src/runtime/testdata')
| -rw-r--r-- | src/runtime/testdata/testprog/synctest.go | 58 |
1 files changed, 58 insertions, 0 deletions
diff --git a/src/runtime/testdata/testprog/synctest.go b/src/runtime/testdata/testprog/synctest.go new file mode 100644 index 0000000000..dd3a6df8a0 --- /dev/null +++ b/src/runtime/testdata/testprog/synctest.go @@ -0,0 +1,58 @@ +// Copyright 2025 The Go Authors. All rights reserved. +// Use of this source code is governed by a BSD-style +// license that can be found in the LICENSE file. + +package main + +import ( + "internal/synctest" + "sync" +) + +func init() { + register("SynctestCond/signal/no_bubble", func() { + synctestCond(func(cond *sync.Cond) { + cond.Signal() + }) + }) + register("SynctestCond/broadcast/no_bubble", func() { + synctestCond(func(cond *sync.Cond) { + cond.Broadcast() + }) + }) + register("SynctestCond/signal/other_bubble", func() { + synctestCond(func(cond *sync.Cond) { + synctest.Run(cond.Signal) + }) + }) + register("SynctestCond/broadcast/other_bubble", func() { + synctestCond(func(cond *sync.Cond) { + synctest.Run(cond.Broadcast) + }) + }) +} + +func synctestCond(f func(*sync.Cond)) { + var ( + mu sync.Mutex + cond = sync.NewCond(&mu) + readyc = make(chan struct{}) + wg sync.WaitGroup + ) + defer wg.Wait() + wg.Go(func() { + synctest.Run(func() { + go func() { + mu.Lock() + defer mu.Unlock() + cond.Wait() + }() + synctest.Wait() + <-readyc // #1: signal that cond.Wait is waiting + <-readyc // #2: wait to continue + cond.Signal() + }) + }) + readyc <- struct{}{} + f(cond) +} |
