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 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
  • 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 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

func (*AtomicBool) WaitWithTimeout

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