106 lines
3.2 KiB
Lua
106 lines
3.2 KiB
Lua
function os.getOS()
|
|
if package.config:sub(1,1)=='\\' then
|
|
return 'windows'
|
|
else
|
|
return 'unix'
|
|
end
|
|
end
|
|
-- Step 1 get lanes
|
|
lanes=require("lanes").configure()
|
|
package.path="lua/?/init.lua;lua/?.lua;"..package.path
|
|
require("multi.updater") -- get it all and have it on all lanes
|
|
local multi=multi
|
|
-- Step 2 set up the linda objects
|
|
local __GlobalLinda = lanes.linda() -- handles global stuff
|
|
local __SleepingLinda = lanes.linda() -- handles sleeping stuff
|
|
-- For convience a GLOBAL table will be constructed to handle requests
|
|
local GLOBAL={}
|
|
setmetatable(GLOBAL,{
|
|
__index=function(t,k)
|
|
return __GlobalLinda:get(k)
|
|
end,
|
|
__newindex=function(t,k,v)
|
|
__GlobalLinda:set(k,v)
|
|
end,
|
|
})
|
|
-- Step 3 rewrite the thread methods to use lindas
|
|
local THREAD={}
|
|
function THREAD.set(name,val)
|
|
__GlobalLinda:set(name,val)
|
|
end
|
|
function THREAD.get(name)
|
|
__GlobalLinda:get(name)
|
|
end
|
|
local function randomString(n)
|
|
local str = ''
|
|
local strings = {'a','b','c','d','e','f','g','h','i','j','k','l','m','n','o','p','q','r','s','t','u','v','w','x','y','z','1','2','3','4','5','6','7','8','9','0','A','B','C','D','E','F','G','H','I','J','K','L','M','N','O','P','Q','R','S','T','U','V','W','X','Y','Z'}
|
|
for i=1,n do
|
|
str = str..''..strings[math.random(1,#strings)]
|
|
end
|
|
return str
|
|
end
|
|
function THREAD.waitFor(name)
|
|
local function wait()
|
|
math.randomseed(os.time())
|
|
__SleepingLinda:receive(.001,randomString(12))
|
|
end
|
|
repeat wait() until __GlobalLinda:get(name)
|
|
return __GlobalLinda:get(name)
|
|
end
|
|
function THREAD.testFor(name,val,sym)
|
|
--
|
|
end
|
|
function THREAD.getCores()
|
|
return THREAD.__CORES
|
|
end
|
|
if os.getOS()=="windows" then
|
|
THREAD.__CORES=tonumber(os.getenv("NUMBER_OF_PROCESSORS"))
|
|
else
|
|
THREAD.__CORES=tonumber(io.popen("nproc --all"):read("*n"))
|
|
end
|
|
function THREAD.kill() -- trigger the lane destruction
|
|
-- coroutine.yield({"_kill_",":)"})
|
|
end
|
|
--[[ Step 4 We need to get sleeping working to handle timing... We want idle wait, not busy wait
|
|
Idle wait keeps the CPU running better where busy wait wastes CPU cycles... Lanes does not have a sleep method
|
|
however, a linda recieve will in fact be a idle wait! So we use that and wrap it in a nice package]]
|
|
function THREAD.sleep(n)
|
|
math.randomseed(os.time())
|
|
__SleepingLinda:receive(n,randomString(12))
|
|
end
|
|
function THREAD.hold(n)
|
|
local function wait()
|
|
math.randomseed(os.time())
|
|
__SleepingLinda:receive(.001,randomString(12))
|
|
end
|
|
repeat wait() until n()
|
|
end
|
|
-- Step 5 Basic Threads!
|
|
function multi:newSystemThread(name,func)
|
|
local c={}
|
|
local __self=c
|
|
c.name=name
|
|
c.thread=lanes.gen("*", func)()
|
|
function c:kill()
|
|
self.status:Destroy()
|
|
self.thread:cancel()
|
|
print("Thread: '"..self.name.."' has been stopped!")
|
|
end
|
|
c.status=multi:newUpdater(multi.Priority_IDLE)
|
|
c.status.link=c
|
|
c.status:OnUpdate(function(self)
|
|
local v,err,t=self.link.thread:join(.001)
|
|
if err then
|
|
print("Error in thread: '"..self.link.name.."' <"..err..">",t)
|
|
self:Destroy()
|
|
end
|
|
end)
|
|
return c
|
|
end
|
|
print("Intergrated Lanes!")
|
|
multi.intergration={} -- for module creators
|
|
multi.intergration.lanes={} -- for module creators
|
|
multi.intergration.lanes.GLOBAL=GLOBAL -- for module creators
|
|
multi.intergration.lanes.THREAD=THREAD -- for module creators
|
|
return {init=function() return GLOBAL,THREAD end}
|