Release cpu during compactions

influxdata · Feb 1, 2017 · 784a851 · 784a851
1 parent 278c144
commit 784a851
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/tsdb/engine/tsm1/compact.go b/tsdb/engine/tsm1/compact.go
@@ -1132,6 +1132,10 @@ func (k *tsmKeyIterator) combine(dedup bool) blocks {
 				}
 
 				k.mergedValues = k.mergedValues.Merge(v)
+
+				// Allow other goroutines to run
+				runtime.Gosched()
+
 			}
 			k.blocks = k.blocks[1:]
 		}
@@ -1144,6 +1148,7 @@ func (k *tsmKeyIterator) combine(dedup bool) blocks {
 		var i int
 
 		for i < len(k.blocks) {
+
 			// skip this block if it's values were already read
 			if k.blocks[i].read() {
 				i++
@@ -1156,6 +1161,8 @@ func (k *tsmKeyIterator) combine(dedup bool) blocks {
 				break
 			}
 			i++
+			// Allow other goroutines to run
+			runtime.Gosched()
 		}
 
 		if k.fast {
@@ -1168,6 +1175,8 @@ func (k *tsmKeyIterator) combine(dedup bool) blocks {
 
 				chunked = append(chunked, k.blocks[i])
 				i++
+				// Allow other goroutines to run
+				runtime.Gosched()
 			}
 		}
 
@@ -1202,6 +1211,8 @@ func (k *tsmKeyIterator) combine(dedup bool) blocks {
 
 			k.mergedValues = k.mergedValues.Merge(v)
 			i++
+			// Allow other goroutines to run
+			runtime.Gosched()
 		}
 
 		k.blocks = k.blocks[i:]