save

AskAlexSharov · AskAlexSharov · commit 7d879349ba9c · 2026-03-03T15:33:22.000+07:00
diff --git a/db/recsplit/recsplit.go b/db/recsplit/recsplit.go
@@ -1276,8 +1276,6 @@ func (rs *RecSplit) buildWithWorkers(ctx context.Context) error {
 	}
 	// taskCh capacity matches the scratch pool size: the same N scratch objects circulate
 	// as both pool items and task payloads, so taskCh can never hold more than N items.
-	// To allow double-buffering (producer assembles bucket N+1 while workers process N),
-	// increase both freeScratchCh and taskCh to numWorkers*2.
 	taskCh := make(chan *recsplitScratch, numWorkers)
 	resultCh := make(chan *bucketResult, numWorkers*2)
 

Original file line number	Diff line number	Diff line change
`@@ -1276,8 +1276,6 @@ func (rs *RecSplit) buildWithWorkers(ctx context.Context) error {`
`1276`	`1276`	`}`
`1277`	`1277`	`// taskCh capacity matches the scratch pool size: the same N scratch objects circulate`
`1278`	`1278`	`// as both pool items and task payloads, so taskCh can never hold more than N items.`
`1279`		`- // To allow double-buffering (producer assembles bucket N+1 while workers process N),`
`1280`		`- // increase both freeScratchCh and taskCh to numWorkers*2.`
`1281`	`1279`	`taskCh := make(chan *recsplitScratch, numWorkers)`
`1282`	`1280`	`resultCh := make(chan bucketResult, numWorkers2)`
`1283`	`1281`