execqueue

func (*ExecQueue) Add ¶

func (q *ExecQueue) Add(f func())

func (*ExecQueue) RunSync ¶

func (q *ExecQueue) RunSync(ctx context.Context, f func()) error

RunSync waits for the queue to be drained and then synchronously runs f. It returns an error if the queue is closed before f is run or ctx expires.

func (*ExecQueue) Shutdown ¶

func (q *ExecQueue) Shutdown()

Shutdown asynchronously signals the queue to stop.

func (*ExecQueue) ShutdownAndWait ¶ added in v1.102.0

func (q *ExecQueue) ShutdownAndWait(ctx context.Context) error

ShutdownAndWait signals the queue to stop, discards any queued functions that have not started, and waits for the currently executing function, if any, to complete or ctx to expire.

It must not be called while holding a lock that a queued function may acquire, or it will not return until ctx expires.

func (*ExecQueue) Wait ¶

func (q *ExecQueue) Wait(ctx context.Context) error

Wait waits for the queue to be empty or shut down.