-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathfloat64.go
More file actions
54 lines (45 loc) · 1.4 KB
/
float64.go
File metadata and controls
54 lines (45 loc) · 1.4 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
// Copyright (c) 2020 Meng Huang (mhboy@outlook.com)
// This package is licensed under a MIT license that can be found in the LICENSE file.
package atomic
import (
"sync/atomic"
"unsafe"
)
// Float64 represents an float64.
type Float64 struct {
v uint64
}
// NewFloat64 returns a new Float64.
func NewFloat64(val float64) *Float64 {
addr := &Float64{}
addr.Store(val)
return addr
}
// Swap atomically stores new into *addr and returns the previous *addr value.
func (addr *Float64) Swap(new float64) (old float64) {
var v = atomic.SwapUint64(&addr.v, *(*uint64)(unsafe.Pointer(&new)))
return *(*float64)(unsafe.Pointer(&v))
}
// CompareAndSwap executes the compare-and-swap operation for an float64 value.
func (addr *Float64) CompareAndSwap(old, new float64) (swapped bool) {
return atomic.CompareAndSwapUint64(&addr.v, *(*uint64)(unsafe.Pointer(&old)), *(*uint64)(unsafe.Pointer(&new)))
}
// Add atomically adds delta to *addr and returns the new value.
func (addr *Float64) Add(delta float64) (new float64) {
for {
old := addr.Load()
new = old + delta
if addr.CompareAndSwap(old, new) {
return
}
}
}
// Load atomically loads *addr.
func (addr *Float64) Load() (val float64) {
var v = atomic.LoadUint64(&addr.v)
return *(*float64)(unsafe.Pointer(&v))
}
// Store atomically stores val into *addr.
func (addr *Float64) Store(val float64) {
atomic.StoreUint64(&addr.v, *(*uint64)(unsafe.Pointer(&val)))
}