tools

Documentation

Index

• func SyncMapLen(m *sync.Map) (len uint32)
• type AtomicInt
  • func NewAtomicInt[T int32 | uint32 | int64 | uint64](data T) *AtomicInt[T]
  • func (a *AtomicInt[T]) Decrease(delta T)
  • func (a *AtomicInt[T]) DecreaseOne()
  • func (a *AtomicInt[T]) Get() T
  • func (a *AtomicInt[T]) Increase(delta T)
  • func (a *AtomicInt[T]) IncreaseOne()
  • func (a *AtomicInt[T]) Set(newData T)
• type GenericsSyncMap
  • func NewGenericsSyncMap[K comparable, V interface{}]() *GenericsSyncMap[K, V]
  • func (g *GenericsSyncMap[K, V]) Delete(key K)
  • func (g *GenericsSyncMap[K, V]) Get(key K) (V, bool)
  • func (g *GenericsSyncMap[K, V]) Len() (len int)
  • func (g *GenericsSyncMap[K, V]) Put(key K, value V)
  • func (g *GenericsSyncMap[K, V]) Range(f func(key K, value V))
• type ProduceConsumerQueue
  • func NewProduceConsumerQueue[T any](ctx context.Context, channelLength int) *ProduceConsumerQueue[T]
  • func (q *ProduceConsumerQueue[T]) Produce(data T) error
  • func (q *ProduceConsumerQueue[T]) RegisterAsyncConsumer(consumerFun func(T)) error
  • func (q *ProduceConsumerQueue[T]) RegisterSyncConsumer(consumerFun func(T)) error

Functions

func SyncMapLen

func SyncMapLen(m *sync.Map) (len uint32)

Types

type AtomicInt

type AtomicInt[T int32 | uint32 | int64 | uint64] struct {
	// contains filtered or unexported fields
}

AtomicInt 原子化操作的

func NewAtomicInt

func NewAtomicInt[T int32 | uint32 | int64 | uint64](data T) *AtomicInt[T]

func (*AtomicInt[T]) Decrease

func (a *AtomicInt[T]) Decrease(delta T)

func (*AtomicInt[T]) DecreaseOne

func (a *AtomicInt[T]) DecreaseOne()

func (*AtomicInt[T]) Get

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

Get 获取

func (*AtomicInt[T]) Increase

func (a *AtomicInt[T]) Increase(delta T)

func (*AtomicInt[T]) IncreaseOne

func (a *AtomicInt[T]) IncreaseOne()

func (*AtomicInt[T]) Set

func (a *AtomicInt[T]) Set(newData T)

Set 设置成新的值

type GenericsSyncMap

type GenericsSyncMap[K any, V interface{}] struct {
	sync.Map
}

func NewGenericsSyncMap

func NewGenericsSyncMap[K comparable, V interface{}]() *GenericsSyncMap[K, V]

func (*GenericsSyncMap[K, V]) Delete

func (g *GenericsSyncMap[K, V]) Delete(key K)

func (*GenericsSyncMap[K, V]) Get

func (g *GenericsSyncMap[K, V]) Get(key K) (V, bool)

func (*GenericsSyncMap[K, V]) Len

func (g *GenericsSyncMap[K, V]) Len() (len int)

func (*GenericsSyncMap[K, V]) Put

func (g *GenericsSyncMap[K, V]) Put(key K, value V)

func (*GenericsSyncMap[K, V]) Range

func (g *GenericsSyncMap[K, V]) Range(f func(key K, value V))

type ProduceConsumerQueue

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

func NewProduceConsumerQueue

func NewProduceConsumerQueue[T any](ctx context.Context, channelLength int) *ProduceConsumerQueue[T]

func (*ProduceConsumerQueue[T]) Produce

func (q *ProduceConsumerQueue[T]) Produce(data T) error

func (*ProduceConsumerQueue[T]) RegisterAsyncConsumer

func (q *ProduceConsumerQueue[T]) RegisterAsyncConsumer(consumerFun func(T)) error

RegisterAsyncConsumer 注册异步消费函数

func (*ProduceConsumerQueue[T]) RegisterSyncConsumer

func (q *ProduceConsumerQueue[T]) RegisterSyncConsumer(consumerFun func(T)) error

RegisterSyncConsumer 注册同步消费函数