Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

concurrent

package module

Go to main page

Versions in this module

v0

v0.0.3-alpha

Dec 17, 2025

v0.0.2

Oct 31, 2025

v0.0.1

Oct 29, 2025

v0.0.0

Oct 26, 2025

Changes in this version

+ var AndUint64 func(u64 *uint64, val uint64) = and64

+ var CompareAndSwapUint128 func(u128 *uint64, old, new [2]uint64) bool = cas128

+ var ErrTemporaryUnavailable = errors.New("temporary unavailable")

+ var OrUint64 func(u64 *uint64, val uint64) = or64

+ func DequeueWait[T any](c Consumer[T]) (elem *T, err error)

+ func DoubleUint64(first, second uint64) (u128 []uint64)

+ func DoubleUintPtr(first, second uintptr) (dw []uintptr)

+ func EnqueueWait[T any](p Producer[T], elem *T) error

+ func NewMPMCQueueIndirect(capacity int) (ConsumerIndirect, ProducerIndirect)

+ func NewMPMCQueue[T any](capacity int) (Consumer[T], Producer[T])

+ func NewMPSCQueue[T any](capacity int) (Consumer[T], Producer[T])

+ func NewQueue[T any](capacity int, opts ...func(opts *QueueOptions)) (Consumer[T], Producer[T])

+ func NewSPMCQueue[T any](capacity int) (Consumer[T], Producer[T])

+ func NewSPSCQueue[T any](capacity int) (Consumer[T], Producer[T])

+ func Pause(cycles ...int)

+ func SetYieldDuration(d time.Duration)

+ func Yield(lv ...int)

+ type Closer interface

+ Close func() error

+ type Consumer interface

+ Dequeue func() (elem *T, err error)

+ type ConsumerIndirect interface

+ Dequeue func() (elem uintptr, err error)

+ type MPMCQueue struct

+ func (q *MPMCQueue[T]) Dequeue() (elem *T, err error)

+ func (q *MPMCQueue[T]) Enqueue(elem *T) error

+ type MPMCQueueIndirect struct

+ func (q *MPMCQueueIndirect) Dequeue() (elem uintptr, err error)

+ func (q *MPMCQueueIndirect) Enqueue(elem uintptr) error

+ type MPSCQueue struct

+ type Producer interface

+ Enqueue func(elem *T) error

+ type ProducerIndirect interface

+ Enqueue func(elem uintptr) error

+ type QueueOptions struct

+ DistinctValues bool

+ LowContention bool

+ SingleConsumer bool

+ SingleProducer bool

+ type SPMCQueue struct

+ type SPSCQueue struct

+ type SpinLock struct

+ func (sl *SpinLock) Lock()

+ func (sl *SpinLock) Unlock()

+ type SpinWait struct

+ func (s *SpinWait) Once()

+ func (s *SpinWait) Reset()

+ func (s *SpinWait) WillYield() bool