summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorruki <[email protected]>2025-11-05 23:31:38 +0800
committerruki <[email protected]>2025-11-07 15:01:57 +0800
commit77216b72f1fe667e5b332446dbf004a71e267de3 (patch)
tree0149d06dc909da54c534bc98ee93d6258dc8f789
parent69393d505d86bdbbc522861045cb41d590c69b72 (diff)
add more logs
-rw-r--r--xmake/core/base/private/async_task.lua7
1 files changed, 6 insertions, 1 deletions
diff --git a/xmake/core/base/private/async_task.lua b/xmake/core/base/private/async_task.lua
index f6698b4ea..7c5baf0df 100644
--- a/xmake/core/base/private/async_task.lua
+++ b/xmake/core/base/private/async_task.lua
@@ -152,6 +152,7 @@ function async_task._loop(event, queue, mutex, is_stopped, is_diagnosis)
if event:wait(-1) > 0 then
-- fetch all tasks from queue at once
+ dprint("async_task: fetching tasks ..")
local cmds = {}
mutex:lock()
while not queue:empty() do
@@ -163,9 +164,11 @@ function async_task._loop(event, queue, mutex, is_stopped, is_diagnosis)
mutex:unlock()
-- execute tasks without holding lock
+ dprint("async_task: handling tasks(%d) ..", #cmds)
for _, cmd in ipairs(cmds) do
_runcmd(cmd)
end
+ dprint("async_task: handle tasks(%d) done", #cmds)
end
end
dprint("async_task: exited")
@@ -187,7 +190,7 @@ function async_task._start()
end
os.atexit(function (errors)
if task_thread then
- utils.dprint("async_task: wait for exiting ..")
+ utils.dprint("async_task: wait the pending tasks(%d) for exiting ..", task_queue:size())
is_stopped = true
-- Perhaps the thread hasn't started yet.
-- Let's wait a while and let it finish executing the tasks in the current queue.
@@ -200,7 +203,9 @@ function async_task._start()
end
task_is_stopped:set(true)
task_event:post()
+ utils.dprint("async_task: wait exiting thread ..")
task_thread:wait(-1)
+ utils.dprint("async_task: wait finished")
end
end)
return true