// Copyright 2021 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 a // A StoppableWaitGroup waits for a collection of goroutines to finish. type StoppableWaitGroup struct { // i is the internal counter which can store tolerate negative values // as opposed the golang's library WaitGroup. i *int64 } // NewStoppableWaitGroup returns a new StoppableWaitGroup. When the 'Stop' is // executed, following 'Add()' calls won't have any effect. func NewStoppableWaitGroup() *StoppableWaitGroup { return &StoppableWaitGroup{ i: func() *int64 { i := int64(0); return &i }(), } }