-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathcyclic-awaitable_bench_test.go
229 lines (208 loc) · 9.5 KB
/
cyclic-awaitable_bench_test.go
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
/*
© 2024–present Harald Rudell <[email protected]> (https://haraldrudell.github.io/haraldrudell/)
All rights reserved
*/
package parl
import (
"reflect"
"runtime"
"sync/atomic"
"testing"
"github.com/haraldrudell/parl/perrors"
"github.com/haraldrudell/parl/pruntime"
)
// Open:closed/Open Ch Close:guaranteed/eventual IsClosed:open/closed
var cyclicAwaitablesuite = []func(b *testing.B){
BenchmarkCaCh,
BenchmarkCaIsClosedTrue,
BenchmarkCaIsClosedFalse,
BenchmarkCaEventuallyConsistentTrue,
BenchmarkCaEventuallyConsistentFalse,
BenchmarkCaOpenOpened,
BenchmarkCaOpenClosed,
}
// Running tool: /opt/homebrew/bin/go test -benchmem -run=^$ -bench ^BenchmarkCyclicAwitable$ github.com/haraldrudell/parl
//
// 250306 c66 AtomicLock: ClosedFalse OpenOpened OpenClosed faster
// BenchmarkCyclicAwitable/BenchmarkCaCh-10 3985760 297.2 ns/op 2.972 wall-ns/op 0 B/op 0 allocs/op
// BenchmarkCyclicAwitable/BenchmarkCaIsClosedTrue-10 4032711 297.4 ns/op 2.974 wall-ns/op 0 B/op 0 allocs/op
// BenchmarkCyclicAwitable/BenchmarkCaIsClosedFalse-10 4046834 297.4 ns/op 2.974 wall-ns/op 0 B/op 0 allocs/op
// BenchmarkCyclicAwitable/BenchmarkCaEventuallyConsistentTrue/BenchmarkEventuallyConsistentTrue-10 576939488 1.953 ns/op 19.53 wall-ns/op 0 B/op 0 allocs/op
// BenchmarkCyclicAwitable/BenchmarkCaEventuallyConsistentFalse/BenchmarkEventuallyConsistentFalse-10 760322566 1.893 ns/op 18.93 wall-ns/op 0 B/op 0 allocs/op
// BenchmarkCyclicAwitable/BenchmarkCaOpenOpened-10 3023618 397.9 ns/op 3.979 wall-ns/op 0 B/op 0 allocs/op
// BenchmarkCyclicAwitable/BenchmarkCaOpenClosed-10 2156744 555.8 ns/op 5.558 wall-ns/op 0 B/op 0 allocs/op
//
// 240517 c66
// pkg: github.com/haraldrudell/parlBenchmarkCyclicAwitable/BenchmarkCaCh-10 4066071 296.8 ns/op 2.968 wall-ns/op 0 B/op 0 allocs/op
// BenchmarkCyclicAwitable/BenchmarkCaIsClosedTrue-10 4500962 267.4 ns/op 2.674 wall-ns/op 0 B/op 0 allocs/op
// BenchmarkCyclicAwitable/BenchmarkCaIsClosedFalse-10 1608205 746.2 ns/op 7.462 wall-ns/op 0 B/op 0 allocs/op
// BenchmarkCyclicAwitable/BenchmarkCaEventuallyConsistentTrue/BenchmarkEventuallyConsistentTrue-10 550551525 1.826 ns/op 18.26 wall-ns/op 0 B/op 0 allocs/op
// BenchmarkCyclicAwitable/BenchmarkCaEventuallyConsistentFalse/BenchmarkEventuallyConsistentFalse-10 631737799 1.718 ns/op 17.18 wall-ns/op 0 B/op 0 allocs/op
// BenchmarkCyclicAwitable/BenchmarkCaOpenOpened-10 1474467 815.4 ns/op 8.154 wall-ns/op 0 B/op 0 allocs/op
// BenchmarkCyclicAwitable/BenchmarkCaOpenClosed-10 1228254 976.9 ns/op 9.769 wall-ns/op 0 B/op 0 allocs/op
func BenchmarkCyclicAwitable(b *testing.B) {
for _, bm := range cyclicAwaitablesuite {
var cL, err = FuncName(bm)
if err != nil {
b.Fatalf("reflect failed: %s", perrors.Short(err))
}
b.Run(cL.FuncIdentifier(), bm)
}
}
// 2.918 ns
//
// 240517 c66
// Running tool: /opt/homebrew/bin/go test -benchmem -run=^$ -bench ^BenchmarkCaCh$ codeberg.org/haraldrudell/goprogramming/pkg/github.com_haraldrudell_parl
// pkg: codeberg.org/haraldrudell/goprogramming/pkg/github.com_haraldrudell_parl
// BenchmarkCaCh-10 3926060 291.8 ns/op 2.918 wall-ns/op 0 B/op 0 allocs/op
func BenchmarkCaCh(b *testing.B) {
var a CyclicAwaitable
var batch = 100
for i := 0; i < b.N; i++ {
for i := 0; i < batch; i++ {
a.Ch()
}
}
b.StopTimer()
b.ReportMetric(float64(b.Elapsed())/float64(b.N)/float64(batch), "wall-ns/op")
}
// [CyclicAwaitable.IsClosed when closed: 2.620 ns
//
// 240517 c66
// Running tool: /opt/homebrew/bin/go test -benchmem -run=^$ -bench ^BenchmarkCaIsClosedTrue$ codeberg.org/haraldrudell/goprogramming/pkg/github.com_haraldrudell_parl
// pkg: codeberg.org/haraldrudell/goprogramming/pkg/github.com_haraldrudell_parl
// BenchmarkCaIsClosedTrue-10 4430820 262.0 ns/op 2.620 wall-ns/op 0 B/op 0 allocs/op
func BenchmarkCaIsClosedTrue(b *testing.B) {
var a CyclicAwaitable
a.Close()
var batch = 100
for i := 0; i < b.N; i++ {
for i := 0; i < batch; i++ {
a.IsClosed()
}
}
b.StopTimer()
b.ReportMetric(float64(b.Elapsed())/float64(b.N)/float64(batch), "wall-ns/op")
}
// [CyclicAwaitable.IsClosed] when open: 6.191 ns
//
// 240517 c66
// Running tool: /opt/homebrew/bin/go test -benchmem -run=^$ -bench ^BenchmarkCaIsClosedFalse$ codeberg.org/haraldrudell/goprogramming/pkg/github.com_haraldrudell_parl
// pkg: codeberg.org/haraldrudell/goprogramming/pkg/github.com_haraldrudell_parl
// BenchmarkCaIsClosedFalse-10 1930954 619.1 ns/op 6.191 wall-ns/op 0 B/op 0 allocs/op
func BenchmarkCaIsClosedFalse(b *testing.B) {
var a CyclicAwaitable
var batch = 100
for i := 0; i < b.N; i++ {
for i := 0; i < batch; i++ {
a.IsClosed()
}
}
b.StopTimer()
b.ReportMetric(float64(b.Elapsed())/float64(b.N)/float64(batch), "wall-ns/op")
}
// 16.12 ns per op
//
// 240517 c66
// Running tool: /opt/homebrew/bin/go test -benchmem -run=^$ -bench ^BenchmarkCaEventuallyConsistentFalse$ codeberg.org/haraldrudell/goprogramming/pkg/github.com_haraldrudell_parl
// pkg: codeberg.org/haraldrudell/goprogramming/pkg/github.com_haraldrudell_parl
// BenchmarkCaEventuallyConsistentFalse/BenchmarkEventuallyConsistentFalse-10 826047098 1.612 ns/op 16.12 wall-ns/op 0 B/op 0 allocs/op
func BenchmarkCaEventuallyConsistentFalse(b *testing.B) {
var ec EventuallyConsistent
b.Run("BenchmarkEventuallyConsistentFalse", NewCaCloseTest(ec).Benchmark)
}
// 16.99 ns
//
// 240517 c66
// Running tool: /opt/homebrew/bin/go test -benchmem -run=^$ -bench ^BenchmarkCaEventuallyConsistentTrue$ codeberg.org/haraldrudell/goprogramming/pkg/github.com_haraldrudell_parl
// pkg: codeberg.org/haraldrudell/goprogramming/pkg/github.com_haraldrudell_parl
// BenchmarkCaEventuallyConsistentTrue/BenchmarkEventuallyConsistentTrue-10 660889242 1.699 ns/op 16.99 wall-ns/op 0 B/op 0 allocs/op
func BenchmarkCaEventuallyConsistentTrue(b *testing.B) {
b.Run("BenchmarkEventuallyConsistentTrue", NewCaCloseTest(EventuallyConsistency).Benchmark)
}
// CaCloseTest tests Awaitable eventually consistent Close
type CaCloseTest struct{ evCon EventuallyConsistent }
// NewAwCloseTest returns a subbenchmark testing Awaitable eventually consistent Close
func NewCaCloseTest(evCon EventuallyConsistent) (a *CaCloseTest) { return &CaCloseTest{evCon: evCon} }
// subbenchmark testing Awaitable eventually consistent Close
func (t *CaCloseTest) Benchmark(b *testing.B) {
var i Atomic64[int]
var p0 atomic.Pointer[CyclicAwaitable]
var a1 CyclicAwaitable
p0.Store(&a1)
b.ResetTimer()
b.RunParallel(func(b *testing.PB) {
var isFirstThread = i.Add(1) == 1
var p = &p0
var a *CyclicAwaitable
var evConArg = t.evCon
for b.Next() {
a = p.Load()
a.Close(evConArg)
if isFirstThread {
var a2 CyclicAwaitable
p.Store(&a2)
}
}
})
b.StopTimer()
b.ReportMetric(float64(b.Elapsed())/float64(b.N)*float64(runtime.GOMAXPROCS(0)), "wall-ns/op")
}
// 6.833 ns
//
// 240517 c66
// Running tool: /opt/homebrew/bin/go test -benchmem -run=^$ -bench ^BenchmarkCaOpenOpened$ codeberg.org/haraldrudell/goprogramming/pkg/github.com_haraldrudell_parl
// pkg: codeberg.org/haraldrudell/goprogramming/pkg/github.com_haraldrudell_parl
// BenchmarkCaOpenOpened-10 1739640 683.3 ns/op 6.833 wall-ns/op 0 B/op 0 allocs/op
func BenchmarkCaOpenOpened(b *testing.B) {
var a CyclicAwaitable
var batch = 100
for i := 0; i < b.N; i++ {
for i := 0; i < batch; i++ {
a.Open()
}
}
b.StopTimer()
b.ReportMetric(float64(b.Elapsed())/float64(b.N)/float64(batch), "wall-ns/op")
}
// 9.736 ns
//
// 240517 c66
// Running tool: /opt/homebrew/bin/go test -benchmem -run=^$ -bench ^BenchmarkCaOpenClosed$ github.com/haraldrudell/parl
// pkg: github.com/haraldrudell/parl
// BenchmarkCaOpenClosed-10 1233966 973.6 ns/op 9.736 wall-ns/op 0 B/op 0 allocs/op
func BenchmarkCaOpenClosed(b *testing.B) {
var closedCyclic, ca CyclicAwaitable
closedCyclic.Close()
var batch = 100
for i := 0; i < b.N; i++ {
for i := 0; i < batch; i++ {
ca.awp.Store(closedCyclic.awp.Load())
closedCyclic.Open()
}
}
b.StopTimer()
b.ReportMetric(float64(b.Elapsed())/float64(b.N)/float64(batch), "wall-ns/op")
}
// preflect.FuncName
func FuncName(funcOrMethod any) (cL *pruntime.CodeLocation, err error) {
// funcOrMethod cannot be nil
if funcOrMethod == nil {
err = NilError("funcOrMethod")
return
}
// funcOrMethod must be underlying type func
var reflectValue = reflect.ValueOf(funcOrMethod)
if reflectValue.Kind() != reflect.Func {
err = perrors.ErrorfPF("funcOrMethod not func: %T", funcOrMethod)
return
}
// get func name, “func1” for anonymous
var runtimeFunc = runtime.FuncForPC(reflectValue.Pointer())
if runtimeFunc == nil {
err = perrors.NewPF("runtime.FuncForPC returned nil")
return
}
cL = pruntime.CodeLocationFromFunc(runtimeFunc)
return
}