File size: 1,193 Bytes
e36aeda | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 | // 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)
}
|