From cb070446adc9f1ac62f7d4a18c625311bf2cc8af Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Tue, 9 Apr 2024 15:05:37 +0800 Subject: [PATCH] 1 --- async_task.go | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/async_task.go b/async_task.go index 3662970..c1996d2 100644 --- a/async_task.go +++ b/async_task.go @@ -11,6 +11,7 @@ type taskLock struct { type AsyncTask struct { status int32 + debugInfo string cb func(*AsyncTask) succCb func(*AsyncTask) failCb func(*AsyncTask) @@ -169,5 +170,18 @@ func NewLockAsyncTask(keys [][]string, cb func(*LockAsyncTask)) *LockAsyncTask { p.lockKeys[lock.key] = lock _app.forcePendingAsyncTask(lock.key).AddTail(&lock.entry) } + if q5.IsDebug() { + p.debugInfo = q5.GetCallStack() + _timer.SetTimeout( + 2, + func (e int32, args* q5.Args) { + if e == q5.TIMER_EXEC_EVENT { + if p.IsRunning() { + _sysLog.Warning("LockAsyncaskTimeOut ", p.debugInfo) + panic("LockAsyncaskTimeOut") + } + } + }) + } return p.init(cb).checkDo() }