aboutsummaryrefslogtreecommitdiff
path: root/tests/benchmarks/increment-stm/stm.go
diff options
context:
space:
mode:
authorEuAndreh <eu@euandre.org>2025-01-23 09:54:11 -0300
committerEuAndreh <eu@euandre.org>2025-01-23 11:36:44 -0300
commit5f6607152a96b85f1518028b8f1ee1ef1aefda75 (patch)
treebe54946ddb2510a317322a2660563c83cab2117c /tests/benchmarks/increment-stm/stm.go
parenttests/stm.go: Turn example into functional test (diff)
downloadstm-5f6607152a96b85f1518028b8f1ee1ef1aefda75.tar.gz
stm-5f6607152a96b85f1518028b8f1ee1ef1aefda75.tar.xz
Move benchmarks from tests/stm.go to tests/benchmarks/*
Diffstat (limited to 'tests/benchmarks/increment-stm/stm.go')
-rw-r--r--tests/benchmarks/increment-stm/stm.go33
1 files changed, 33 insertions, 0 deletions
diff --git a/tests/benchmarks/increment-stm/stm.go b/tests/benchmarks/increment-stm/stm.go
new file mode 100644
index 0000000..9f12eb1
--- /dev/null
+++ b/tests/benchmarks/increment-stm/stm.go
@@ -0,0 +1,33 @@
+package stm
+
+import (
+ "flag"
+)
+
+
+
+var nFlag = flag.Int(
+ "n",
+ 1_000,
+ "The number of iterations to execute",
+)
+
+func MainTest() {
+ flag.Parse()
+ n := *nFlag
+
+ for i := 0; i < n; i++ {
+ // swap 1000 goroutines that each increment v by 1
+ v := NewVar(0)
+ for i := 0; i < 1000; i++ {
+ go Atomically(VoidOperation(func(tx *Tx) {
+ v.Set(tx, v.Get(tx) + 1)
+ }))
+ }
+
+ // wait for v to reach 1000
+ Atomically(VoidOperation(func(tx *Tx) {
+ tx.Assert(v.Get(tx) == 1000)
+ }))
+ }
+}