Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

Go to main page

Versions in this module

v0

v0.4.1

Apr 19, 2020

Changes in this version

type Deadline

+ Expired func() bool

+ Remaining func() time.Duration

v0.4.0

Apr 18, 2020

v0.3.0

Apr 18, 2020

Changes in this version

+ func Nop()

v0.2.0

Apr 18, 2020

v0.1.0

Apr 18, 2020

Changes in this version

+ const DefaultConcurrency

+ const DefaultCounterCheckInterval

+ const DefaultReferenceCheckInterval

+ const DefaultScoreboardCheckInterval

+ const Indefinitely

+ func Forever(parent context.Context) (context.Context, context.CancelFunc)

+ func Timeout(parent context.Context, timeout time.Duration) (context.Context, context.CancelFunc)

+ type AtomicCounter interface

+ Add func(amount int64) int64

+ Await func(cond I64Condition, timeout time.Duration, interval ...time.Duration) int64

+ AwaitCtx func(ctx context.Context, cond I64Condition, interval ...time.Duration) int64

+ CompareAndSwap func(expected int64, replacement int64) bool

+ Dec func() int64

+ Drain func(atMost int64, timeout time.Duration, interval ...time.Duration) int64

+ Fill func(atLeast int64, timeout time.Duration, interval ...time.Duration) int64

+ Get func() int64

+ GetInt func() int

+ Inc func() int64

+ Set func(amount int64)

+ func NewAtomicCounter(initial ...int64) AtomicCounter

+ type AtomicReference interface

+ Await func(cond RefCondition, timeout time.Duration, interval ...time.Duration) interface{}

+ AwaitCtx func(ctx context.Context, cond RefCondition, interval ...time.Duration) interface{}

+ Get func() interface{}

+ Set func(value interface{})

+ func NewAtomicReference(initial ...interface{}) AtomicReference

+ type Deadline interface

+ Elapsed func() time.Duration

+ Lapsed func() bool

+ Last func() time.Time

+ Move func(new time.Time)

+ TryRun func(f func()) bool

+ func NewDeadline(interval time.Duration) Deadline

+ type I64Condition func(value int64) bool

+ func I64Equal(target int64) I64Condition

+ func I64GreaterThan(target int64) I64Condition

+ func I64GreaterThanOrEqual(target int64) I64Condition

+ func I64LessThan(target int64) I64Condition

+ func I64LessThanOrEqual(target int64) I64Condition

+ func I64Not(cond I64Condition) I64Condition

+ type RefCondition func(referent interface{}) bool

+ func RefEqual(target interface{}) RefCondition

+ func RefNil() RefCondition

+ func RefNot(cond RefCondition) RefCondition

+ type Scoreboard interface

+ Add func(key string, amount int64) int64

+ Await func(key string, cond I64Condition, timeout time.Duration, ...) int64

+ AwaitCtx func(ctx context.Context, key string, cond I64Condition, interval ...time.Duration) int64

+ Clear func()

+ Dec func(key string) int64

+ Drain func(key string, atMost int64, timeout time.Duration, interval ...time.Duration) int64

+ Fill func(key string, atLeast int64, timeout time.Duration, interval ...time.Duration) int64

+ Get func(key string) int64

+ GetInt func(key string) int

+ Inc func(key string) int64

+ Set func(key string, value int64)

+ View func() map[string]int64

+ func NewScoreboard(concurrency ...int) Scoreboard