adtosync

type ADTOSync ¶

type ADTOSync struct {
	Invalidated bool
	// contains filtered or unexported fields
}

func (ds *ADTOSync) SealWithTimeout(ctxUp context.Context, to time.Duration)

func (ds *ADTOSync) Unseal()

func (ds *ADTOSync) Wait() (err error)

type FastAsyncOnce ¶

type FastAsyncOnce struct {
	// contains filtered or unexported fields
}

func (o *Once) Do(f func()) {
	// Note: Here is an incorrect implementation of Do:
	//
	//	if atomic.CompareAndSwapUint32(&o.done, 0, 1) {
	//		f()
	//	}
	//
	// Do guarantees that when it returns, f has finished.
	// This implementation would not implement that guarantee:
	// given two simultaneous calls, the winner of the cas would
	// call f, and the second would return immediately, without
	// waiting for the first's call to f to complete.
	// This is why the slow path falls back to a mutex, and why
	// the atomic.StoreUint32 must be delayed until after f returns.

p.s. we don't need that guarantee here, therefore need a CAS specifically

func (o *FastAsyncOnce) Do(f func())