epicknex/multi
1
0
Fork 0
Code Issues 5 Pull Requests 1 Actions Packages Projects Releases 13 Wiki Activity

Fixed issue with how the thread scheduler spawned threads

Browse Source
This commit is contained in:
Ryan Ward 2022-02-15 21:47:07 -05:00
parent 04d5500374
commit fc18a303dd
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
multi/init.lua
View File

@ -1516,7 +1516,7 @@ co_status = {
local handler = coroutine.wrap(function(self) local handler = coroutine.wrap(function(self)
local temp_start local temp_start
while true do while true do
for start = 1, #startme do for start = #startme, 1, -1 do
temp_start = startme[start] temp_start = startme[start]
table.remove(startme) table.remove(startme)
_,ret,r1,r2,r3,r4,r5,r6,r7,r8,r9,r10,r11,r12,r13,r14,r15,r16 = resume(temp_start.thread,unpack(temp_start.startArgs)) _,ret,r1,r2,r3,r4,r5,r6,r7,r8,r9,r10,r11,r12,r13,r14,r15,r16 = resume(temp_start.thread,unpack(temp_start.startArgs))
@ -1540,10 +1540,11 @@ end)
function multi:createHandler(threads,startme) function multi:createHandler(threads,startme)
return coroutine.wrap(function(self) return coroutine.wrap(function(self)
local temp_start
while true do while true do
for start = #startme, 1, -1 do for start = #startme, 1, -1 do
temp_start = startme[start] temp_start = startme[start]
table.remove(startme[start]) table.remove(startme)
_,ret,r1,r2,r3,r4,r5,r6,r7,r8,r9,r10,r11,r12,r13,r14,r15,r16 = resume(temp_start.thread,unpack(temp_start.startArgs)) _,ret,r1,r2,r3,r4,r5,r6,r7,r8,r9,r10,r11,r12,r13,r14,r15,r16 = resume(temp_start.thread,unpack(temp_start.startArgs))
co_status[status(temp_start.thread)](temp_start.thread,temp_start,t_none,nil,threads) -- Make sure there was no error co_status[status(temp_start.thread)](temp_start.thread,temp_start,t_none,nil,threads) -- Make sure there was no error
table.insert(threads,temp_start) table.insert(threads,temp_start)