Plan on testing parity between the threading modules

This commit is contained in:
Ryan Ward 2023-04-20 23:23:51 -04:00
parent c65b850529
commit 8e6d174f20
4 changed files with 7 additions and 2 deletions

View File

@ -1,7 +1,7 @@
# Changelog # Changelog
Table of contents Table of contents
--- ---
[Update 16.0.0 - ?](#update-1600---?)</br> [Update 16.0.0 - Connecting the dots](#update-1600---connecting-the-dots)</br>
[Update 15.3.1 - Bug fix](#update-1531---bug-fix)</br> [Update 15.3.1 - Bug fix](#update-1531---bug-fix)</br>
[Update 15.3.0 - A world of connections](#update-1530---a-world-of-connections)</br> [Update 15.3.0 - A world of connections](#update-1530---a-world-of-connections)</br>
[Update 15.2.1 - Bug fix](#update-1521---bug-fix)</br> [Update 15.2.1 - Bug fix](#update-1521---bug-fix)</br>
@ -58,7 +58,7 @@ Table of contents
[Update: EventManager 1.0.0 - Error checking](#update-eventmanager-100---error-checking)</br> [Update: EventManager 1.0.0 - Error checking](#update-eventmanager-100---error-checking)</br>
[Version: EventManager 0.0.1 - In The Beginning things were very different](#version-eventmanager-001---in-the-beginning-things-were-very-different) [Version: EventManager 0.0.1 - In The Beginning things were very different](#version-eventmanager-001---in-the-beginning-things-were-very-different)
# Update 16.0.0 - ? # Update 16.0.0 - Connecting the dots
Added Added
--- ---
- Connection objects now support the % function. This supports a function % connection object. What it does is allow you to **mod**ify the incoming arguments of a connection event. - Connection objects now support the % function. This supports a function % connection object. What it does is allow you to **mod**ify the incoming arguments of a connection event.

View File

@ -27,6 +27,7 @@ if not (GLOBAL and THREAD) then
else else
lanes = require("lanes") lanes = require("lanes")
end end
function multi:newSystemThreadedQueue(name) function multi:newSystemThreadedQueue(name)
local name = name or multi.randomString(16) local name = name or multi.randomString(16)
local c = {} local c = {}

View File

@ -69,6 +69,7 @@ function multi:newSystemThreadedQueue(name)
THREAD.package(name,c) THREAD.package(name,c)
return c return c
end end
function multi:newSystemThreadedTable(name) function multi:newSystemThreadedTable(name)
local name = name or multi.randomString(16) local name = name or multi.randomString(16)
local c = {} local c = {}
@ -79,6 +80,7 @@ function multi:newSystemThreadedTable(name)
THREAD.package(name,c) THREAD.package(name,c)
return c return c
end end
local jqc = 1 local jqc = 1
function multi:newSystemThreadedJobQueue(n) function multi:newSystemThreadedJobQueue(n)
local c = {} local c = {}

View File

@ -50,6 +50,7 @@ function multi:newSystemThreadedQueue(name)
GLOBAL[name or "_"] = c GLOBAL[name or "_"] = c
return c return c
end end
function multi:newSystemThreadedTable(name) function multi:newSystemThreadedTable(name)
local c = {} local c = {}
function c:init() function c:init()
@ -68,6 +69,7 @@ if not setfenv then
end end
end end
end end
function multi:newSystemThreadedJobQueue(n) function multi:newSystemThreadedJobQueue(n)
local c = {} local c = {}
c.cores = n or THREAD.getCores()*2 c.cores = n or THREAD.getCores()*2