sync

package

v0.6.0 Latest Latest Go to latest Published: Jan 3, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

func BufferedChannel[T any](n int) (sender *ChannelSender[T], receiver *ChannelReceiver[T])

func UnbufferedChannel[T any]() (sender *ChannelSender[T], receiver *ChannelReceiver[T])

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

func (r *ChannelReceiver[T]) Range(f func(T))

func (r *ChannelReceiver[T]) Receive() (v T, ok bool)

func (r *ChannelReceiver[T]) ReceiveTimeout(duration time.Duration) (v T, ok bool)

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

func (cs *ChannelSender[T]) Close()

func (cs *ChannelSender[T]) Send(v T) bool

func (cs *ChannelSender[T]) SendTimeout(v T, duration time.Duration) bool

type Map[K any, V any] struct {
	// contains filtered or unexported fields
}

Map is generic version of sync.Map.

func (self *Map[K, V]) Delete(key K)

func (self *Map[K, V]) Get(key K) (V, bool)

func (self *Map[K, V]) GetOptional(key K) optional.Optional[V]

func (self *Map[K, V]) GetOrPut(key K, val V) (V, bool)

func (self *Map[K, V]) Insert(key K, v V)

func (self *Map[K, V]) Range(fn func(K, V) bool)

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

Pool is generic version of sync.Pool

func NewPool[T any](fn func() *T) *Pool[T]

func (self *Pool[T]) Get() *T

func (self *Pool[T]) Put(val *T)