mtcontrib/async
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Pass nil to callback function

Browse Source
This commit is contained in:
Coder12a 2018-11-10 21:27:33 -06:00
parent c7b1458e21
commit a7786b4829
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
async.lua
View File

@ -149,7 +149,7 @@ end
function extended_api.Async.chain_task(pool,tasks,callback) function extended_api.Async.chain_task(pool,tasks,callback)
extended_api.Async.create_worker(pool,function() extended_api.Async.create_worker(pool,function()
local pass_arg = {} local pass_arg = nil
local last_time = minetest.get_us_time() * 1000 local last_time = minetest.get_us_time() * 1000
local maxtime = pool.maxtime local maxtime = pool.maxtime
for index, task_func in pairs(tasks) do for index, task_func in pairs(tasks) do
@ -174,14 +174,14 @@ function extended_api.Async.queue_task(pool,func,callback)
if pool.queue_threads > 0 then if pool.queue_threads > 0 then
pool.queue_threads = pool.queue_threads - 1 pool.queue_threads = pool.queue_threads - 1
extended_api.Async.create_worker(pool,function() extended_api.Async.create_worker(pool,function()
local pass_arg = {} local pass_arg = nil
local last_time = minetest.get_us_time() * 1000 local last_time = minetest.get_us_time() * 1000
local maxtime = pool.maxtime local maxtime = pool.maxtime
while(true) do while(true) do
local task_func = pool.task_queue[1] local task_func = pool.task_queue[1]
table.remove(pool.task_queue,1) table.remove(pool.task_queue,1)
if task_func and task_func.func then if task_func and task_func.func then
pass_arg = {} pass_arg = nil
local p = task_func.func(pass_arg) local p = task_func.func(pass_arg)
if p then if p then
pass_arg = p pass_arg = p