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
|
package repl
import (
"sync"
"testing"
"codeberg.org/snonux/gt/internal/rpn"
)
// TestConcurrentExecutor tests concurrent calls to defaultExecutor with fresh state
func TestConcurrentExecutor(t *testing.T) {
var wg sync.WaitGroup
for i := 0; i < 10; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
vars := rpn.NewVariables()
rpnCalc := rpn.NewRPN(vars, nil)
rpl := &REPL{
ttyChecker: &TTYChecker{},
historyMgr: NewHistoryManager(".gt_history"),
signalHandler: NewSignalHandler(),
commandChain: NewCommandChain(),
rpnState: &RPNState{vars: vars, rpnCalc: rpnCalc},
}
defaultExecutor(rpl, "20% of 150")
}(i)
}
wg.Wait()
}
// TestConcurrentRPN tests concurrent inline RPN evaluation
func TestConcurrentRPN(t *testing.T) {
var wg sync.WaitGroup
for i := 0; i < 10; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
vars := rpn.NewVariables()
rpnCalc := rpn.NewRPN(vars, nil)
_, _ = rpnCalc.ParseAndEvaluate("3 4 +")
}(i)
}
wg.Wait()
}
// TestConcurrentRatModeToggle tests concurrent rat mode toggles with fresh state
func TestConcurrentRatModeToggle(t *testing.T) {
var wg sync.WaitGroup
for i := 0; i < 10; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
vars := rpn.NewVariables()
rpnCalc := rpn.NewRPN(vars, nil)
rpl := &REPL{
ttyChecker: &TTYChecker{},
historyMgr: NewHistoryManager(".gt_history"),
signalHandler: NewSignalHandler(),
commandChain: NewCommandChain(),
rpnState: &RPNState{vars: vars, rpnCalc: rpnCalc},
}
defaultExecutor(rpl, "rat toggle")
}(i)
}
wg.Wait()
}
// TestConcurrentExecutorAndRPN tests concurrent executor and RPN calls with fresh state
func TestConcurrentExecutorAndRPN(t *testing.T) {
var wg sync.WaitGroup
for i := 0; i < 5; i++ {
wg.Add(2)
go func(id int) {
defer wg.Done()
vars := rpn.NewVariables()
rpnCalc := rpn.NewRPN(vars, nil)
rpl := &REPL{
ttyChecker: &TTYChecker{},
historyMgr: NewHistoryManager(".gt_history"),
signalHandler: NewSignalHandler(),
commandChain: NewCommandChain(),
rpnState: &RPNState{vars: vars, rpnCalc: rpnCalc},
}
defaultExecutor(rpl, "20% of 150")
}(i)
go func(id int) {
defer wg.Done()
vars := rpn.NewVariables()
rpnCalc := rpn.NewRPN(vars, nil)
_, _ = rpnCalc.ParseAndEvaluate("3 4 +")
}(i)
}
wg.Wait()
}
|
