🎨 改进内核任务调度机制提升稳定性 https://github.com/siyuan-note/siyuan/issues/7113

kernel/main.go

@@ -52,7 +52,7 @@ func main() {
 	util.PushClearAllMsg()
 	go model.AutoRefreshCheck()
 	go model.AutoFlushTx()
-	go sql.AutoFlushQueue()
+	go sql.AutoFlushTx()
 	go treenode.AutoFlushBlockTree()
 	go cache.LoadAssets()
 	go model.AutoFixIndex()

kernel/mobile/kernel.go

@@ -66,7 +66,7 @@ func StartKernel(container, appDir, workspaceBaseDir, timezoneID, localIPs, lang
 		util.PushClearAllMsg()
 		go model.AutoRefreshCheck()
 		go model.AutoFlushTx()
-		go sql.AutoFlushQueue()
+		go sql.AutoFlushTx()
 		go treenode.AutoFlushBlockTree()
 		go cache.LoadAssets()
 		go model.AutoFixIndex()

kernel/model/ocr.go

@@ -1,7 +1,6 @@
 package model
 
 import (
-	"github.com/dustin/go-humanize"
 	"io"
 	"os"
 	"path/filepath"
@@ -12,9 +11,11 @@ import (
 	"time"
 
 	"github.com/88250/gulu"
+	"github.com/dustin/go-humanize"
 	"github.com/panjf2000/ants/v2"
 	"github.com/siyuan-note/logging"
 	"github.com/siyuan-note/siyuan/kernel/cache"
+	"github.com/siyuan-note/siyuan/kernel/task"
 	"github.com/siyuan-note/siyuan/kernel/util"
 )
 
@@ -24,7 +25,7 @@ func AutoOCRAssets() {
 	}
 
 	for {
-		autoOCRAssets()
+		task.AppendTask(task.OCRImage, autoOCRAssets)
 		time.Sleep(7 * time.Second)
 	}
 }

kernel/sql/queue.go

@@ -29,6 +29,7 @@ import (
 	"github.com/emirpasic/gods/sets/hashset"
 	"github.com/siyuan-note/eventbus"
 	"github.com/siyuan-note/logging"
+	"github.com/siyuan-note/siyuan/kernel/task"
 	"github.com/siyuan-note/siyuan/kernel/util"
 )
 
@@ -50,10 +51,10 @@ type treeQueueOperation struct {
 	renameTreeOldHPath            string      // rename
 }
 
-func AutoFlushTreeQueue() {
+func AutoFlushTx() {
 	for {
-		flushTreeQueue()
 		time.Sleep(util.SQLFlushInterval)
+		task.PrependTask(task.DatabaseIndex, FlushQueue)
 	}
 }
 
@@ -91,7 +92,7 @@ func ClearQueue() {
 	operationQueue = nil
 }
 
-func flushTreeQueue() {
+func FlushQueue() {
 	ops := mergeUpsertTrees()
 	if 1 > len(ops) {
 		return