Merge pull request #268 from onflow/rbtz/limitGoRoutines

Limit number of goroutines in FastCommit()
onflow · Jun 3, 2022 · 9de15f4 · 9de15f4
2 parents 525fbc2 + f439666
commit 9de15f4
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/storage.go b/storage.go
@@ -733,6 +733,11 @@ func (s *PersistentSlabStorage) FastCommit(numWorkers int) error {
 		return nil
 	}
 
+	// limit the number of workers to the number of keys
+	if numWorkers > len(keysWithOwners) {
+		numWorkers = len(keysWithOwners)
+	}
+
 	// construct job queue
 	jobs := make(chan StorageID, len(keysWithOwners))
 	for _, id := range keysWithOwners {