syncext

Documentation

Index

• func ReadChannelWithTimeout[T any](c chan T, timeout time.Duration) (T, bool)
• type AtomicBool
  • func NewAtomicBool(value bool) *AtomicBool
  • func (a *AtomicBool) Get() bool
  • func (a *AtomicBool) Set(value bool)
  • func (a *AtomicBool) Wait(waitFor bool)
  • func (a *AtomicBool) WaitWithContext(ctx context.Context, waitFor bool) error

Functions

func ReadChannelWithTimeout

func ReadChannelWithTimeout[T any](c chan T, timeout time.Duration) (T, bool)

Types

type AtomicBool

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

func NewAtomicBool

func NewAtomicBool(value bool) *AtomicBool

func (*AtomicBool) Get

func (a *AtomicBool) Get() bool

func (*AtomicBool) Set

func (a *AtomicBool) Set(value bool)

func (*AtomicBool) Wait

func (a *AtomicBool) Wait(waitFor bool)

func (*AtomicBool) WaitWithContext

func (a *AtomicBool) WaitWithContext(ctx context.Context, waitFor bool) error