Shutdown analysis queue (blevesearch#1414)

terranZY · Oct 6, 2020 · 3bb3c7b · 3bb3c7b
1 parent bffe7ea
commit 3bb3c7b
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/config.go b/config.go
@@ -43,9 +43,16 @@ type configuration struct {
 }
 
 func (c *configuration) SetAnalysisQueueSize(n int) {
+	if c.analysisQueue != nil {
+		c.analysisQueue.Close()
+	}
 	c.analysisQueue = index.NewAnalysisQueue(n)
 }
 
+func (c *configuration) Shutdown() {
+	c.SetAnalysisQueueSize(0)
+}
+
 func newConfiguration() *configuration {
 	return &configuration{
 		Cache:         registry.NewCache(),