Batch write

.github/workflows/main.yml

@@ -10,13 +10,12 @@ jobs:
       - name: Setup Go
         uses: actions/setup-go@v1
         with:
-          go-version: 1.13
+          go-version: 1.17
         id: go
       - name: Code checkout
         uses: actions/checkout@v1
       - name: Test
         run: |
-          go test -v ./... -coverprofile=coverage.txt -covermode=atomic
           go test -v ./... -race
       - name: Build
         run: |

bigcache.go

@@ -1,10 +1,9 @@
-package fastcache
+package turbocache
 
 import (
+	xxhash "github.com/cespare/xxhash/v2"
 	"sync"
 	"sync/atomic"
-
-	xxhash "github.com/cespare/xxhash/v2"
 )
 
 // maxSubvalueLen is the maximum size of subvalue chunk.
@@ -55,13 +54,13 @@ func (c *Cache) SetBig(k, v []byte) {
 		}
 		subvalue := v[:subvalueLen]
 		v = v[subvalueLen:]
-		c.Set(subkey.B, subvalue)
+		c.setSync(subkey.B, subvalue)
 	}
 
 	// Write metavalue, which consists of valueHash and valueLen.
 	subkey.B = marshalUint64(subkey.B[:0], valueHash)
 	subkey.B = marshalUint64(subkey.B, uint64(valueLen))
-	c.Set(k, subkey.B)
+	c.setSync(k, subkey.B)
 	putSubkeyBuf(subkey)
 }
 

bigcache_test.go

@@ -1,4 +1,4 @@
-package fastcache
+package turbocache
 
 import (
 	"bytes"
@@ -7,7 +7,7 @@ import (
 )
 
 func TestSetGetBig(t *testing.T) {
-	c := New(256 * 1024 * 1024)
+	c := New(NewConfig(256*1024*1024, 3, 100))
 	const valuesCount = 10
 	for _, valueSize := range []int{1, 100, 1<<16 - 1, 1 << 16, 1<<16 + 1, 1 << 17, 1<<17 + 1, 1<<17 - 1, 1 << 19} {
 		t.Run(fmt.Sprintf("valueSize_%d", valueSize), func(t *testing.T) {
@@ -32,7 +32,7 @@ func testSetGetBig(t *testing.T, c *Cache, valueSize, valuesCount, seed int) {
 		}
 	}
 	var s Stats
-	c.UpdateStats(&s)
+	c.UpdateStats(&s, false)
 	if s.SetBigCalls < uint64(valuesCount) {
 		t.Fatalf("expecting SetBigCalls >= %d; got %d", valuesCount, s.SetBigCalls)
 	}

bigcache_timing_test.go

@@ -1,4 +1,4 @@
-package fastcache
+package turbocache
 
 import (
 	"testing"
@@ -7,7 +7,7 @@ import (
 func BenchmarkSetBig(b *testing.B) {
 	key := []byte("key12345")
 	value := createValue(256*1024, 0)
-	c := New(1024 * 1024)
+	c := New(NewSyncWriteConfig(1024 * 1024))
 	b.SetBytes(int64(len(value)))
 	b.ReportAllocs()
 	b.RunParallel(func(pb *testing.PB) {
@@ -20,7 +20,7 @@ func BenchmarkSetBig(b *testing.B) {
 func BenchmarkGetBig(b *testing.B) {
 	key := []byte("key12345")
 	value := createValue(265*1024, 0)
-	c := New(1024 * 1024)
+	c := New(NewSyncWriteConfig(1024 * 1024))
 	c.SetBig(key, value)
 	b.SetBytes(int64(len(value)))
 	b.ReportAllocs()