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

Do: not run schedule again on thread death

Browse Source
This commit is contained in:
Coder12a 2019-04-17 19:08:36 -05:00
parent 1de4e9d070
commit 48649de608
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
async.lua
View File

@ -27,7 +27,6 @@ function extended_api.Async()
local thread = self.pool.threads[index] local thread = self.pool.threads[index]
if not thread or coroutine.status(thread) == "dead" then if not thread or coroutine.status(thread) == "dead" then
table.remove(self.pool.threads, index) table.remove(self.pool.threads, index)
minetest.after(0, self.schedule_worker)
return false return false
else else
coroutine.resume(thread) coroutine.resume(thread)
@ -40,7 +39,6 @@ function extended_api.Async()
local thread = self.pool.globalstep_threads[index] local thread = self.pool.globalstep_threads[index]
if not thread or coroutine.status(thread) == "dead" then if not thread or coroutine.status(thread) == "dead" then
table.remove(self.pool.globalstep_threads, index) table.remove(self.pool.globalstep_threads, index)
minetest.after(0, self.schedule_globalstep_worker)
return false return false
else else
coroutine.resume(thread) coroutine.resume(thread)
@ -99,7 +97,7 @@ function extended_api.Async()
local last_time = minetest.get_us_time() / 1000 local last_time = minetest.get_us_time() / 1000
local maxtime = self.pool.maxtime local maxtime = self.pool.maxtime
for k,v in ipairs(array) do for k,v in ipairs(array) do
local b = func(k,v) local b = func(k, v)
if b ~= nil and b == false then if b ~= nil and b == false then
break break
end end