| // Copyright 2025 The Go Authors. All rights reserved. |
| // Use of this source code is governed by a MIT |
| // license that can be found in the LICENSE file. |
| |
| package main |
| |
| import ( |
| "os" |
| "runtime/pprof" |
| "sync" |
| "sync/atomic" |
| "time" |
| ) |
| |
| func init() { |
| register("Cockroach1055", Cockroach1055) |
| } |
| |
| type Stopper_cockroach1055 struct { |
| stopper chan struct{} |
| stop sync.WaitGroup |
| mu sync.Mutex |
| draining int32 |
| drain sync.WaitGroup |
| } |
| |
| func (s *Stopper_cockroach1055) AddWorker() { |
| s.stop.Add(1) |
| } |
| |
| func (s *Stopper_cockroach1055) ShouldStop() <-chan struct{} { |
| if s == nil { |
| return nil |
| } |
| return s.stopper |
| } |
| |
| func (s *Stopper_cockroach1055) SetStopped() { |
| if s != nil { |
| s.stop.Done() |
| } |
| } |
| |
| func (s *Stopper_cockroach1055) Quiesce() { |
| s.mu.Lock() |
| defer s.mu.Unlock() |
| atomic.StoreInt32(&s.draining, 1) |
| s.drain.Wait() |
| atomic.StoreInt32(&s.draining, 0) |
| } |
| |
| func (s *Stopper_cockroach1055) Stop() { |
| s.mu.Lock() // L1 |
| defer s.mu.Unlock() |
| atomic.StoreInt32(&s.draining, 1) |
| s.drain.Wait() |
| close(s.stopper) |
| s.stop.Wait() |
| } |
| |
| func (s *Stopper_cockroach1055) StartTask() bool { |
| if atomic.LoadInt32(&s.draining) == 0 { |
| s.mu.Lock() |
| defer s.mu.Unlock() |
| s.drain.Add(1) |
| return true |
| } |
| return false |
| } |
| |
| func NewStopper_cockroach1055() *Stopper_cockroach1055 { |
| return &Stopper_cockroach1055{ |
| stopper: make(chan struct{}), |
| } |
| } |
| |
| func Cockroach1055() { |
| prof := pprof.Lookup("goroutineleak") |
| defer func() { |
| time.Sleep(100 * time.Millisecond) |
| prof.WriteTo(os.Stdout, 2) |
| }() |
| |
| for i := 0; i <= 1000; i++ { |
| go func() { // G1 |
| var stoppers []*Stopper_cockroach1055 |
| for i := 0; i < 2; i++ { |
| stoppers = append(stoppers, NewStopper_cockroach1055()) |
| } |
| |
| for i := range stoppers { |
| s := stoppers[i] |
| s.AddWorker() |
| go func() { // G2 |
| s.StartTask() |
| <-s.ShouldStop() |
| s.SetStopped() |
| }() |
| } |
| |
| done := make(chan struct{}) |
| go func() { // G3 |
| for _, s := range stoppers { |
| s.Quiesce() |
| } |
| for _, s := range stoppers { |
| s.Stop() |
| } |
| close(done) |
| }() |
| |
| <-done |
| }() |
| } |
| } |