syncutil

Documentation

Overview

Package syncutil adds functions for synchronization.

Index

• func Wait(ctx context.Context, wg *sync.WaitGroup) error
• type AtomicInt
  • func NewAtomicInt(value int32) *AtomicInt
  • func (i *AtomicInt) Set(value int32)
  • func (i *AtomicInt) Value() int32

Functions

func Wait

func Wait(ctx context.Context, wg *sync.WaitGroup) error

Wait for a sync.WaitGroup with support for timeout/cancellations from context.

Types

type AtomicInt

type AtomicInt int32

AtomicInt uses sync/atomic to store and read the value of an int32.

func NewAtomicInt

func NewAtomicInt(value int32) *AtomicInt

NewAtomicInt creates an new AtomicInt.

func (*AtomicInt) Set

func (i *AtomicInt) Set(value int32)

func (*AtomicInt) Value

func (i *AtomicInt) Value() int32