Versions in this module Expand all Collapse all v0 v0.5.0 Nov 21, 2024 Changes in this version + type ConcurrentMap struct + func NewConcurrentMap() *ConcurrentMap + func (m *ConcurrentMap) Delete(key interface{}) + func (m *ConcurrentMap) Get(key interface{}) (interface{}, bool) + func (m *ConcurrentMap) Put(key, value interface{}) + func (m *ConcurrentMap) Size() int + type ConcurrentQueue struct + func NewConcurrentQueue() *ConcurrentQueue + func (q *ConcurrentQueue) Dequeue() (interface{}, bool) + func (q *ConcurrentQueue) Enqueue(item interface{}) + func (q *ConcurrentQueue) Size() int + type ConcurrentSet struct + func NewConcurrentSet() *ConcurrentSet + func (s *ConcurrentSet) Add(item interface{}) + func (s *ConcurrentSet) Contains(item interface{}) bool + func (s *ConcurrentSet) Remove(item interface{}) + func (s *ConcurrentSet) Size() int + type Counter struct + func NewCounter() *Counter + func (c *Counter) Decrement() + func (c *Counter) Increment() + func (c *Counter) Value() int + type Semaphore struct + func NewSemaphore(max int) *Semaphore + func (s *Semaphore) Acquire() + func (s *Semaphore) Release() + type WorkerPool struct + func NewWorkerPool(workerCount int) *WorkerPool + func (p *WorkerPool) Shutdown() + func (p *WorkerPool) Submit(task func())
Go to main page