syncext

Documentation

Index

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

Functions

func ReadChannelWithTimeout

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

func ReadNonBlocking

func ReadNonBlocking[T any](c chan T) (T, bool)

func WriteChannelWithTimeout

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

func WriteNonBlocking

func WriteNonBlocking[T any](c chan T, msg T) bool

Types

type Atomic

type Atomic[T any] struct {
	// contains filtered or unexported fields
}

func NewAtomic

func NewAtomic[T any](value T) *Atomic[T]

func (*Atomic[T]) Get

func (a *Atomic[T]) Get() T

func (*Atomic[T]) Set

func (a *Atomic[T]) Set(value T) T

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) bool

func (*AtomicBool) Wait

func (a *AtomicBool) Wait(waitFor bool)

func (*AtomicBool) WaitWithContext

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

func (*AtomicBool) WaitWithTimeout

func (a *AtomicBool) WaitWithTimeout(timeout time.Duration, waitFor bool) error