Andreas/siyuan
1
0
Fork 0
mirror of https://github.com/siyuan-note/siyuan.git synced 2025-12-17 07:00:12 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

♻️ 重构定时任务实现 https://github.com/siyuan-note/siyuan/issues/7171

Browse source
This commit is contained in:
Liang Ding 2023-01-26 23:31:34 +08:00
parent df9122b664
commit 4d7f46a433
No known key found for this signature in database
GPG key ID: 136F30F901A2231D
1 changed files with 2 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

21
kernel/task/queue.go
View file

@ -32,11 +32,6 @@ var (
queueLock = sync.Mutex{} queueLock = sync.Mutex{}
) )
const (
QueueStatusRunning = iota
QueueStatusClosing
)
type Task struct { type Task struct {
Action string Action string
Handler reflect.Value Handler reflect.Value
@ -48,7 +43,7 @@ func PrependTask(action string, handler interface{}, args ...interface{}) {
queueLock.Lock() queueLock.Lock()
defer queueLock.Unlock() defer queueLock.Unlock()
if QueueStatusRunning != taskQueueStatus { if util.IsExiting {
//logging.LogWarnf("task queue is paused, action [%s] will be ignored", action) //logging.LogWarnf("task queue is paused, action [%s] will be ignored", action)
return return
} }
@ -61,7 +56,7 @@ func AppendTask(action string, handler interface{}, args ...interface{}) {
queueLock.Lock() queueLock.Lock()
defer queueLock.Unlock() defer queueLock.Unlock()
if QueueStatusRunning != taskQueueStatus { if util.IsExiting {
//logging.LogWarnf("task queue is paused, action [%s] will be ignored", action) //logging.LogWarnf("task queue is paused, action [%s] will be ignored", action)
return return
} }
@ -150,11 +145,6 @@ func StatusJob() {
} }
func ExecTaskJob() { func ExecTaskJob() {
if QueueStatusClosing == taskQueueStatus {
clearQueue()
return
}
task := popTask() task := popTask()
if nil == task { if nil == task {
return return
@ -167,13 +157,6 @@ func ExecTaskJob() {
execTask(task) execTask(task)
} }
func clearQueue() {
queueLock.Lock()
defer queueLock.Unlock()
taskQueue = []*Task{}
}
func popTask() (ret *Task) { func popTask() (ret *Task) {
queueLock.Lock() queueLock.Lock()
defer queueLock.Unlock() defer queueLock.Unlock()