[#98] Remove batch processing

maypok86 · Jul 29, 2024 · b2a4cbb · b2a4cbb
1 parent c4ac892
commit b2a4cbb
Showing 1 changed file with 3 additions and 18 deletions.
diff --git a/internal/core/cache.go b/internal/core/cache.go
@@ -443,29 +443,14 @@ func (c *Cache[K, V]) onWrite(t task[K, V]) {
 func (c *Cache[K, V]) process() {
 	for {
 		t := c.writeBuffer.Pop()
+
 		c.evictionMutex.Lock()
 		c.onWrite(t)
+		c.evictionMutex.Unlock()
+
 		if t.isClose() {
-			c.evictionMutex.Unlock()
 			break
-		} else if t.isClear() {
-			c.evictionMutex.Unlock()
-			continue
-		}
-		for i := uint32(0); i < maxWriteBufferSize; i++ {
-			t, ok := c.writeBuffer.TryPop()
-			if !ok {
-				break
-			}
-			c.onWrite(t)
-			if t.isClose() {
-				c.evictionMutex.Unlock()
-				return
-			} else if t.isClear() {
-				break
-			}
 		}
-		c.evictionMutex.Unlock()
 	}
 }