🎨 降低重建索引内存占用 Fix https://github.com/siyuan-note/siyuan/issues/7268

kernel/model/box.go

@@ -506,6 +506,9 @@ func ReloadUI() {
 
 func FullReindex() {
 	task.PrependTask(task.DatabaseIndexFull, fullReindex)
+	task.AppendTask(task.DatabaseCache, sql.EnableCache)
+	task.AppendTask(task.DatabaseIndexRef, IndexRefs)
+	task.AppendTask(task.ReloadUI, util.ReloadUI)
 }
 
 func fullReindex() {
@@ -523,12 +526,9 @@ func fullReindex() {
 	for _, openedBox := range openedBoxes {
 		index(openedBox.ID)
 	}
-	sql.EnableCache()
 	treenode.SaveBlockTree(true)
 	LoadFlashcards()
-	IndexRefs()
 	debug.FreeOSMemory()
-	util.ReloadUI()
 }
 
 func ChangeBoxSort(boxIDs []string) {

kernel/model/history.go

@@ -244,7 +244,6 @@ func RollbackDocHistory(boxID, historyPath string) (err error) {
 
 	FullReindex()
 	IncSync()
-	ReloadUI()
 	return nil
 }
 

kernel/model/import.go

@@ -441,7 +441,6 @@ func ImportData(zipPath string) (err error) {
 
 	IncSync()
 	FullReindex()
-	ReloadUI()
 	return
 }
 

kernel/model/repository.go

@@ -541,7 +541,6 @@ func checkoutRepo(id string) {
 	}
 
 	FullReindex()
-	ReloadUI()
 
 	if syncEnabled {
 		func() {
@@ -1028,9 +1027,6 @@ func syncRepo(exit, byHand bool) (err error) {
 	cache.ClearDocsIAL()              // 同步后文档树文档图标没有更新 https://github.com/siyuan-note/siyuan/issues/4939
 	if needFullReindex(upsertTrees) { // 改进同步后全量重建索引判断 https://github.com/siyuan-note/siyuan/issues/5764
 		FullReindex()
-		if !exit {
-			ReloadUI()
-		}
 		return
 	}
 

kernel/model/sync.go

@@ -97,7 +97,9 @@ func SyncData(boot, exit, byHand bool) {
 func syncData(boot, exit, byHand bool) {
 	defer logging.Recover()
 
+	util.BroadcastByType("main", "syncing", 0, Conf.Language(81), nil)
 	if !checkSync(boot, exit, byHand) {
+		util.BroadcastByType("main", "syncing", 1, "", nil)
 		return
 	}
 
@@ -118,7 +120,6 @@ func syncData(boot, exit, byHand bool) {
 	now := util.CurrentTimeMillis()
 	Conf.Sync.Synced = now
 
-	util.BroadcastByType("main", "syncing", 0, Conf.Language(81), nil)
 	err := syncRepo(exit, byHand)
 	synced := util.Millisecond2Time(Conf.Sync.Synced).Format("2006-01-02 15:04:05") + "\n\n"
 	if nil == err {

kernel/task/queue.go

@@ -79,6 +79,7 @@ const (
 	DatabaseIndexCommit     = "task.database.index.commit"     // 数据库索引提交
 	DatabaseIndexRef        = "task.database.index.ref"        // 数据库索引引用
 	DatabaseIndexFix        = "task.database.index.fix"        // 数据库索引订正
+	DatabaseCache           = "task.database.cache"            // 数据库缓存
 	OCRImage                = "task.ocr.image"                 // 图片 OCR 提取文本
 	HistoryGenerateDoc      = "task.history.generateDoc"       // 生成文件历史
 	DatabaseIndexEmbedBlock = "task.database.index.embedBlock" // 数据库索引嵌入块
@@ -105,8 +106,8 @@ func StatusJob() {
 	for _, task := range tasks {
 		actionLangs := util.TaskActionLangs[util.Lang]
 		action := task.Action
-		if c := count[action]; 3 < c {
-			logging.LogWarnf("too many tasks [%s], ignore show its status", action)
+		if c := count[action]; 2 < c {
+			//logging.LogWarnf("too many tasks [%s], ignore show its status", action)
 			continue
 		}
 		count[action]++
@@ -165,7 +166,7 @@ func execTask(task *Task) {
 		}
 	}
 
-	ctx, cancel := context.WithTimeout(context.Background(), time.Second*7)
+	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Minute)
 	defer cancel()
 	ch := make(chan bool, 1)
 	go func() {
@@ -175,7 +176,7 @@ func execTask(task *Task) {
 
 	select {
 	case <-ctx.Done():
-		//logging.LogWarnf("task [%s] timeout", task.Action)
+		logging.LogWarnf("task [%s] timeout", task.Action)
 	case <-ch:
 		//logging.LogInfof("task [%s] done", task.Action)
 	}