2016-06-01 13:38:57 +03:00
|
|
|
// Package abool provides atomic Boolean type for cleaner code and
|
2016-05-25 07:06:29 +03:00
|
|
|
// better performance.
|
2016-05-25 06:42:19 +03:00
|
|
|
package abool
|
|
|
|
|
2021-04-28 17:48:48 +03:00
|
|
|
import (
|
|
|
|
"encoding/json"
|
|
|
|
"sync/atomic"
|
|
|
|
)
|
2016-05-25 06:42:19 +03:00
|
|
|
|
2020-07-16 09:07:17 +03:00
|
|
|
// New creates an AtomicBool with default set to false.
|
2016-05-25 06:42:19 +03:00
|
|
|
func New() *AtomicBool {
|
|
|
|
return new(AtomicBool)
|
|
|
|
}
|
|
|
|
|
2020-07-16 09:07:17 +03:00
|
|
|
// NewBool creates an AtomicBool with given default value.
|
2016-05-25 10:06:49 +03:00
|
|
|
func NewBool(ok bool) *AtomicBool {
|
|
|
|
ab := New()
|
|
|
|
if ok {
|
|
|
|
ab.Set()
|
|
|
|
}
|
|
|
|
return ab
|
|
|
|
}
|
|
|
|
|
2020-07-16 09:07:17 +03:00
|
|
|
// AtomicBool is an atomic Boolean.
|
|
|
|
// Its methods are all atomic, thus safe to be called by multiple goroutines simultaneously.
|
|
|
|
// Note: When embedding into a struct one should always use *AtomicBool to avoid copy.
|
2016-05-25 06:42:19 +03:00
|
|
|
type AtomicBool int32
|
|
|
|
|
2020-07-16 09:07:17 +03:00
|
|
|
// Set sets the Boolean to true.
|
2016-05-25 06:42:19 +03:00
|
|
|
func (ab *AtomicBool) Set() {
|
|
|
|
atomic.StoreInt32((*int32)(ab), 1)
|
|
|
|
}
|
|
|
|
|
2020-07-16 09:07:17 +03:00
|
|
|
// UnSet sets the Boolean to false.
|
2016-05-25 06:42:19 +03:00
|
|
|
func (ab *AtomicBool) UnSet() {
|
|
|
|
atomic.StoreInt32((*int32)(ab), 0)
|
|
|
|
}
|
|
|
|
|
2020-07-16 09:07:17 +03:00
|
|
|
// IsSet returns whether the Boolean is true.
|
2016-05-25 06:42:19 +03:00
|
|
|
func (ab *AtomicBool) IsSet() bool {
|
2020-06-30 05:10:19 +03:00
|
|
|
return atomic.LoadInt32((*int32)(ab))&1 == 1
|
2016-05-25 06:42:19 +03:00
|
|
|
}
|
2016-05-25 09:57:10 +03:00
|
|
|
|
2020-07-16 09:46:58 +03:00
|
|
|
// IsNotSet returns whether the Boolean is false.
|
|
|
|
func (ab *AtomicBool) IsNotSet() bool {
|
|
|
|
return !ab.IsSet()
|
|
|
|
}
|
|
|
|
|
2019-07-22 08:11:38 +03:00
|
|
|
// SetTo sets the boolean with given Boolean.
|
2016-05-25 09:57:10 +03:00
|
|
|
func (ab *AtomicBool) SetTo(yes bool) {
|
|
|
|
if yes {
|
|
|
|
atomic.StoreInt32((*int32)(ab), 1)
|
|
|
|
} else {
|
|
|
|
atomic.StoreInt32((*int32)(ab), 0)
|
|
|
|
}
|
|
|
|
}
|
2016-06-02 06:47:41 +03:00
|
|
|
|
2020-07-16 09:07:17 +03:00
|
|
|
// Toggle inverts the Boolean then returns the value before inverting.
|
2020-07-07 10:33:59 +03:00
|
|
|
func (ab *AtomicBool) Toggle() bool {
|
|
|
|
return atomic.AddInt32((*int32)(ab), 1)&1 == 0
|
2018-09-07 17:17:26 +03:00
|
|
|
}
|
|
|
|
|
2020-07-16 09:07:17 +03:00
|
|
|
// SetToIf sets the Boolean to new only if the Boolean matches the old.
|
|
|
|
// Returns whether the set was done.
|
2016-06-02 06:47:41 +03:00
|
|
|
func (ab *AtomicBool) SetToIf(old, new bool) (set bool) {
|
|
|
|
var o, n int32
|
|
|
|
if old {
|
|
|
|
o = 1
|
|
|
|
}
|
|
|
|
if new {
|
|
|
|
n = 1
|
|
|
|
}
|
|
|
|
return atomic.CompareAndSwapInt32((*int32)(ab), o, n)
|
|
|
|
}
|
2021-04-28 17:48:48 +03:00
|
|
|
|
|
|
|
// Marshal an AtomicBool into JSON like a normal bool
|
|
|
|
func (ab *AtomicBool) MarshalJSON() ([]byte, error) {
|
|
|
|
return json.Marshal(ab.IsSet())
|
|
|
|
}
|
|
|
|
|
|
|
|
// Unmarshall normal bool's into AtomicBool
|
|
|
|
func (ab *AtomicBool) UnmarshalJSON(b []byte) error {
|
2021-05-04 20:26:17 +03:00
|
|
|
var v bool
|
2021-04-28 17:48:48 +03:00
|
|
|
if err := json.Unmarshal(b, &v); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
2021-05-04 20:29:53 +03:00
|
|
|
ab.SetTo(v)
|
|
|
|
return nil
|
2021-04-28 17:48:48 +03:00
|
|
|
}
|