Ryan
7601fc636d
Added: SystemThreadedBenchmark SystemThreadedQueue Fixed a bunch of bugs in the intergrations and regular multi objects Fixed Error management in threads All errors trigger the multi.OnError connection Module creation support improved added more examples added Type to threaded objects
28 lines
691 B
Lua
28 lines
691 B
Lua
local GLOBAL,sThread=require("multi.intergration.lanesManager").init()
|
|
queue=multi:newSystemThreadedQueue("QUEUE"):init()
|
|
queue:push("This is a test")
|
|
queue:push("This is a test2")
|
|
queue:push("This is a test3")
|
|
queue:push("This is a test4")
|
|
multi:newSystemThread("test2",function()
|
|
queue=sThread.waitFor("QUEUE"):init()
|
|
data=queue:pop()
|
|
while data do
|
|
print(data)
|
|
data=queue:pop()
|
|
end
|
|
queue:push("This is a test5")
|
|
queue:push("This is a test6")
|
|
queue:push("This is a test7")
|
|
queue:push("This is a test8")
|
|
end)
|
|
multi:newThread("test!",function() -- this is a lua thread
|
|
thread.sleep(.1)
|
|
data=queue:pop()
|
|
while data do
|
|
print(data)
|
|
data=queue:pop()
|
|
end
|
|
end)
|
|
multi:mainloop()
|