"runtime"
"runtime/metrics"
"sync/atomic"
+ "unsafe"
)
// This program ensures system goroutines (GC workers, finalizer goroutine)
return samples[0].Value.Uint64()
}
+type T struct {
+ v int
+ p unsafe.Pointer
+}
+
func main() {
// Channels created by a finalizer and cleanup func registered within the bubble.
var (
synctest.Run(func() {
// Start the finalizer and cleanup goroutines.
{
- p := new(int)
- runtime.SetFinalizer(p, func(*int) {
+ p := new(T)
+ runtime.SetFinalizer(p, func(*T) {
ch := make(chan struct{})
finalizerCh.Store(&ch)
})
}, struct{}{})
}
startingCycles := numGCCycles()
- ch1 := make(chan *int)
- ch2 := make(chan *int)
+ ch1 := make(chan *T)
+ ch2 := make(chan *T)
defer close(ch1)
go func() {
- for i := range ch1 {
- v := *i + 1
- ch2 <- &v
+ for range ch1 {
+ ch2 <- &T{}
}
}()
- for {
+ const iterations = 1000
+ for range iterations {
// Make a lot of short-lived allocations to get the GC working.
- for i := 0; i < 1000; i++ {
- v := new(int)
- *v = i
+ for range 1000 {
+ v := new(T)
// Set finalizers on these values, just for added stress.
- runtime.SetFinalizer(v, func(*int) {})
+ runtime.SetFinalizer(v, func(*T) {})
ch1 <- v
<-ch2
}
// If we've improperly put a GC goroutine into the synctest group,
// this Wait is going to hang.
- //synctest.Wait()
+ synctest.Wait()
// End the test after a couple of GC cycles have passed.
if numGCCycles()-startingCycles > 1 && finalizerCh.Load() != nil && cleanupCh.Load() != nil {
- break
+ return
}
}
+ println("finalizers/cleanups failed to run after", iterations, "cycles")
})
// Close the channels created by the finalizer and cleanup func.
// If the funcs improperly ran inside the bubble, these channels are bubbled