1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
require "luaproc"
result, error_msg = luaproc.createworker()
if not result then print(error_msg) end
result, error_msg = luaproc.createworker()
if not result then print(error_msg) end
result, error_msg = luaproc.createworker()
if not result then print(error_msg) end
result, error_msg = luaproc.createworker()
if not result then print(error_msg) end
count = 0
for i = 1, 10 do
local proc = [=[
require "string"
local channel = "channel%d"
local message
result, error_msg = luaproc.newchannel(channel)
if not result then print(error_msg) end
repeat
message = luaproc.receive(channel)
local x, y = string.find(message, "@")
if not x then
x, y = string.find(message, "@")
x, y = string.find(message, "@")
x, y = string.find(message, "@")
x, y = string.find(message, "@")
x, y = string.find(message, "@")
x, y = string.find(message, "@")
x, y = string.find(message, "@")
x, y = string.find(message, "@")
end
until "quit" == message
]=]
proc = string.format(proc, i)
-- print(proc)
result, error_msg = luaproc.newproc(proc)
if not result then print(error_msg) else count = count + 1 end
end
print("Started " .. count .. " Lua threads.")
mainProc = [=[
local count = %d
local messages = 0
local length = 0
local message = "This is a test message. 56789 12"
if 0 ~= count then
for k = 0, 16 do
for j = 0, 199 do
for i = 1, count do
result, error_msg = luaproc.send("channel" .. i, message)
if not result then print(error_msg .. " " .. i) else
messages = messages + 1
length = length + #message
end
end
end
message = message .. message
end
for i = 1, count do
result, error_msg = luaproc.send("channel" .. i, "quit")
if not result then print(error_msg .. " " .. i) end
end
end
print("Sent " .. messages .. " messages totalling " .. length .. " bytes. The largest message was " .. #message .. " bytes.")
]=]
mainProc = string.format(mainProc, count)
result, error_msg = luaproc.newproc(mainProc)
if not result then print(error_msg) end
luaproc.exit()
|
