syncutil

package

v0.6.3 Latest Latest Go to latest Published: Apr 3, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ChannelTicker struct {
	C chan time.Time
}

func (t *ChannelTicker) Chan() <-chan time.Time

func (t *ChannelTicker) Stop()

func (t *ChannelTicker) Tick()

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

func NewGValue[T any](t T) *GValue[T]

func (v *GValue[T]) CompareAndSwap(oldval T, newval T) bool

func (v *GValue[T]) Init()

func (v *GValue[T]) Load() T

func (v *GValue[T]) Store(val T)

func (v *GValue[T]) Swap(newval T) T

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

func NewOnceDisposable() *OnceDisposable

func (o *OnceDisposable) Dispose(ctx context.Context, f func(ctx context.Context) error) error

func (o *OnceDisposable) Do(ctx context.Context, f func(ctx context.Context) error) error

type Ticker interface {
	Chan() <-chan time.Time
	Stop()
	Tick()
}

type TimeTicker struct {
	Ticker *time.Ticker
}

func (t *TimeTicker) Chan() <-chan time.Time

func (t *TimeTicker) Stop()

func (t *TimeTicker) Tick()