Ryan Ward
7eb9cd37e9
Fixed some systemthreaded objects. More tests are needed though. About to start making real documentation soon!
37 lines
812 B
Lua
37 lines
812 B
Lua
package.path="?/init.lua;?.lua;"..package.path
|
|
multi = require("multi")
|
|
local GLOBAL, THREAD = require("multi.integration.lanesManager").init()
|
|
conn = multi:newSystemThreadedConnection("test"):init()
|
|
multi:newSystemThread("Work",function()
|
|
local multi = require("multi")
|
|
conn = THREAD.waitFor("test"):init()
|
|
conn(function(...)
|
|
print(...)
|
|
end)
|
|
multi:newTLoop(function()
|
|
conn:Fire("meh2")
|
|
end,1)
|
|
multi:mainloop()
|
|
end)
|
|
multi.OnError(function(a,b,c)
|
|
print(c)
|
|
end)
|
|
multi:newTLoop(function()
|
|
conn:Fire("meh")
|
|
end,1)
|
|
conn(function(...)
|
|
print(">",...)
|
|
end)
|
|
|
|
--~ jq = multi:newSystemThreadedJobQueue()
|
|
--~ jq:registerJob("test",function(a)
|
|
--~ return "Hello",a
|
|
--~ end)
|
|
--~ jq.OnJobCompleted(function(ID,...)
|
|
--~ print(ID,...)
|
|
--~ end)
|
|
--~ for i=1,16 do
|
|
--~ jq:pushJob("test",5)
|
|
--~ end
|
|
multi:mainloop()
|