AskaEth/Cyrene
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

fix: storeThought orphaned lock → defer unlock

Browse Source
This commit is contained in:
AskaEth
2026-06-28 16:16:35 +08:00
parent dc410c1cff
commit 24d7722ef9
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/ai-core/internal/background/thinker.go
+1 -1
View File
@@ -1895,6 +1895,7 @@ func (t *Thinker) buildOpenAITools() []llm.OpenAITool {
// storeThought 存储思考结果到待推送队列，并异步持久化到 memory-service // storeThought 存储思考结果到待推送队列，并异步持久化到 memory-service
func (t *Thinker) storeThought(content string, toolCallsJSON string, toolCallCount int) { func (t *Thinker) storeThought(content string, toolCallsJSON string, toolCallCount int) {
t.muLock() t.muLock()
defer t.muUnlock()
t.pendingThoughts = append(t.pendingThoughts, &PendingThought{ t.pendingThoughts = append(t.pendingThoughts, &PendingThought{
Content: content, Content: content,
CreatedAt: time.Now(), CreatedAt: time.Now(),
@@ -1951,7 +1952,6 @@ func (t *Thinker) storeThought(content string, toolCallsJSON string, toolCallCou
copy := *proactiveTarget copy := *proactiveTarget
targetCopy = &copy targetCopy = &copy
} }
t.muUnlock()
log.Printf("[后台思考] 思考已存储 (当前累积 %d 条待推送思考)", len(t.pendingThoughts)) log.Printf("[后台思考] 思考已存储 (当前累积 %d 条待推送思考)", len(t.pendingThoughts))