concurrenz

Documentation

Index

• type AtomicBitSet
  • func (self *AtomicBitSet) CompareAndSet(index int, current, next bool) bool
  • func (self *AtomicBitSet) CompareAndSetAll(current, next uint32) bool
  • func (self *AtomicBitSet) IsSet(index int) bool
  • func (self *AtomicBitSet) Load() uint32
  • func (self *AtomicBitSet) Set(index int, val bool)
  • func (self *AtomicBitSet) Store(val uint32)
• type AtomicBoolean
  • func (ab *AtomicBoolean) CompareAndSwap(expected, val bool) bool
  • func (ab *AtomicBoolean) Get() bool
  • func (ab *AtomicBoolean) GetUnsafe() bool
  • func (ab *AtomicBoolean) Set(val bool)
  • func (ab *AtomicBoolean) WaitForState(val bool, timeout time.Duration, pollInterval time.Duration) error
• type AtomicString
  • func (ab *AtomicString) Get() string
  • func (ab *AtomicString) Set(val string)

Types

type AtomicBitSet

type AtomicBitSet uint32

func (*AtomicBitSet) CompareAndSet

func (self *AtomicBitSet) CompareAndSet(index int, current, next bool) bool

func (*AtomicBitSet) CompareAndSetAll

func (self *AtomicBitSet) CompareAndSetAll(current, next uint32) bool

func (*AtomicBitSet) IsSet

func (self *AtomicBitSet) IsSet(index int) bool

func (*AtomicBitSet) Load

func (self *AtomicBitSet) Load() uint32

func (*AtomicBitSet) Set

func (self *AtomicBitSet) Set(index int, val bool)

func (*AtomicBitSet) Store

func (self *AtomicBitSet) Store(val uint32)

type AtomicBoolean

type AtomicBoolean int32

func (*AtomicBoolean) CompareAndSwap

func (ab *AtomicBoolean) CompareAndSwap(expected, val bool) bool

CompareAndSwap sets the given value only if the current value is equal to expected. return true if the swap was made

func (*AtomicBoolean) Get

func (ab *AtomicBoolean) Get() bool

func (*AtomicBoolean) GetUnsafe

func (ab *AtomicBoolean) GetUnsafe() bool

GetUnsafe returns the value if you are sure you are getting from the same thread as the last set This is only useful if you only set from one goroutine and are only using Get to sync access across other threads. GetUnsafe can then be used from the Set goroutine

func (*AtomicBoolean) Set

func (ab *AtomicBoolean) Set(val bool)

func (*AtomicBoolean) WaitForState

func (ab *AtomicBoolean) WaitForState(val bool, timeout time.Duration, pollInterval time.Duration) error

type AtomicString

type AtomicString atomic.Value

func (*AtomicString) Get

func (ab *AtomicString) Get() string

func (*AtomicString) Set

func (ab *AtomicString) Set(val string)