Merge branch 'main' of github.com:alphadose/haxmap

Author: alphadose

Diff for: benchmarks/go.mod

@@ -7,9 +7,7 @@ replace github.com/alphadose/haxmap => ../
 require (
 	github.com/alphadose/haxmap v0.0.0-00010101000000-000000000000
 	github.com/cornelk/hashmap v1.0.8
+	github.com/puzpuzpuz/xsync/v2 v2.3.1
 )
 
-require (
-	github.com/cespare/xxhash v1.1.0 // indirect
-	golang.org/x/exp v0.0.0-20221031165847-c99f073a8326 // indirect
-)
+require golang.org/x/exp v0.0.0-20221031165847-c99f073a8326 // indirect

Diff for: benchmarks/go.sum

@@ -1,20 +1,6 @@
-github.com/OneOfOne/xxhash v1.2.2 h1:KMrpdQIwFcEqXDklaen+P1axHaj9BSKzvpUUfnHldSE=
-github.com/OneOfOne/xxhash v1.2.2/go.mod h1:HSdplMjZKSmBqAxg5vPj2TmRDmfkzw+cTzAElWljhcU=
-github.com/cespare/xxhash v1.1.0 h1:a6HrQnmkObjyL+Gs60czilIUGqrzKutQD6XZog3p+ko=
-github.com/cespare/xxhash v1.1.0/go.mod h1:XrSqR1VqqWfGrhpAt58auRo0WTKS1nRRg3ghfAqPWnc=
-github.com/cornelk/hashmap v1.0.5 h1:FetMxz5XPtcXrP1hIbAhsCGyj6L4aa8E+wLS5UrqKm8=
-github.com/cornelk/hashmap v1.0.5/go.mod h1:DqXRj31DMSQGWQJit5c3jpIErEoTlZYmKhAlBGrf0Sw=
-github.com/cornelk/hashmap v1.0.6 h1:ZNxfMue8uqQdjI36f7e8o8JqqQMcz5ybk7AH5EqfoQM=
-github.com/cornelk/hashmap v1.0.6/go.mod h1:DqXRj31DMSQGWQJit5c3jpIErEoTlZYmKhAlBGrf0Sw=
-github.com/cornelk/hashmap v1.0.7 h1:9W5NPASHKJ13gl37bgHNPT4rntj1YFGl5a1Uro7HpA8=
-github.com/cornelk/hashmap v1.0.7/go.mod h1:RfZb7JO3RviW/rT6emczVuC/oxpdz4UsSB2LJSclR1k=
 github.com/cornelk/hashmap v1.0.8 h1:nv0AWgw02n+iDcawr5It4CjQIAcdMMKRrs10HOJYlrc=
 github.com/cornelk/hashmap v1.0.8/go.mod h1:RfZb7JO3RviW/rT6emczVuC/oxpdz4UsSB2LJSclR1k=
-github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
-github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
-github.com/spaolacci/murmur3 v0.0.0-20180118202830-f09979ecbc72 h1:qLC7fQah7D6K1B0ujays3HV9gkFtllcxhzImRR7ArPQ=
-github.com/spaolacci/murmur3 v0.0.0-20180118202830-f09979ecbc72/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=
-github.com/stretchr/testify v1.8.0 h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk=
+github.com/puzpuzpuz/xsync/v2 v2.3.1 h1:oAm/nI4ZC+FqOM7t2fnA7DaQVsuj4fO2KcTcNTS1Q9Y=
+github.com/puzpuzpuz/xsync/v2 v2.3.1/go.mod h1:gD2H2krq/w52MfPLE+Uy64TzJDVY7lP2znR9qmR35kU=
 golang.org/x/exp v0.0.0-20221031165847-c99f073a8326 h1:QfTh0HpN6hlw6D3vu8DAwC8pBIwikq0AI1evdm+FksE=
 golang.org/x/exp v0.0.0-20221031165847-c99f073a8326/go.mod h1:CxIveKay+FTh1D0yPZemJVgC/95VzuuOLq5Qi4xnoYc=
-gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=

Diff for: benchmarks/map_test.go

@@ -7,6 +7,7 @@ import (
 
 	"github.com/alphadose/haxmap"
 	"github.com/cornelk/hashmap"
+	"github.com/puzpuzpuz/xsync/v2"
 )
 
 const (
@@ -30,14 +31,22 @@ func setupGoSyncMap() *sync.Map {
 	return m
 }
 
-func setupCornelkMap(b *testing.B) *hashmap.Map[uintptr, uintptr] {
+func setupCornelkMap() *hashmap.Map[uintptr, uintptr] {
 	m := hashmap.NewSized[uintptr, uintptr](mapSize)
 	for i := uintptr(0); i < epochs; i++ {
 		m.Set(i, i)
 	}
 	return m
 }
 
+func setupXsyncMap() *xsync.MapOf[uintptr, uintptr] {
+	m := xsync.NewIntegerMapOf[uintptr, uintptr]()
+	for i := uintptr(0); i < epochs; i++ {
+		m.Store(i, i)
+	}
+	return m
+}
+
 func BenchmarkHaxMapReadsOnly(b *testing.B) {
 	m := setupHaxMap()
 	b.ResetTimer()
@@ -119,7 +128,7 @@ func BenchmarkGoSyncMapReadsWithWrites(b *testing.B) {
 }
 
 func BenchmarkCornelkMapReadsOnly(b *testing.B) {
-	m := setupCornelkMap(b)
+	m := setupCornelkMap()
 	b.ResetTimer()
 	b.RunParallel(func(pb *testing.PB) {
 		for pb.Next() {
@@ -134,7 +143,7 @@ func BenchmarkCornelkMapReadsOnly(b *testing.B) {
 }
 
 func BenchmarkCornelkMapReadsWithWrites(b *testing.B) {
-	m := setupCornelkMap(b)
+	m := setupCornelkMap()
 	var writer uintptr
 	b.ResetTimer()
 	b.RunParallel(func(pb *testing.PB) {
@@ -157,3 +166,43 @@ func BenchmarkCornelkMapReadsWithWrites(b *testing.B) {
 		}
 	})
 }
+
+func BenchmarkXsyncMapReadsOnly(b *testing.B) {
+	m := setupXsyncMap()
+	b.ResetTimer()
+	b.RunParallel(func(pb *testing.PB) {
+		for pb.Next() {
+			for i := uintptr(0); i < epochs; i++ {
+				j, _ := m.Load(i)
+				if j != i {
+					b.Fail()
+				}
+			}
+		}
+	})
+}
+
+func BenchmarkXsyncMapReadsWithWrites(b *testing.B) {
+	m := setupXsyncMap()
+	var writer uintptr
+	b.ResetTimer()
+	b.RunParallel(func(pb *testing.PB) {
+		// use 1 thread as writer
+		if atomic.CompareAndSwapUintptr(&writer, 0, 1) {
+			for pb.Next() {
+				for i := uintptr(0); i < epochs; i++ {
+					m.Store(i, i)
+				}
+			}
+		} else {
+			for pb.Next() {
+				for i := uintptr(0); i < epochs; i++ {
+					j, _ := m.Load(i)
+					if j != i {
+						b.Fail()
+					}
+				}
+			}
+		}
+	})
+}