diff options
Diffstat (limited to 'tests/basic.lua')
-rw-r--r-- | tests/basic.lua | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/tests/basic.lua b/tests/basic.lua index 020fe78..6fcfd53 100644 --- a/tests/basic.lua +++ b/tests/basic.lua | |||
@@ -114,7 +114,7 @@ collectgarbage() | |||
114 | 114 | ||
115 | PRINT( "\n\n", "---=== Tasking (cancelling) ===---", "\n\n") | 115 | PRINT( "\n\n", "---=== Tasking (cancelling) ===---", "\n\n") |
116 | 116 | ||
117 | local task_launch2= lanes_gen( "", { cancelstep=100, globals={hey=true}, gc_cb = gc_cb}, task ) | 117 | local task_launch2= lanes_gen( "", { globals={hey=true}, gc_cb = gc_cb}, task ) |
118 | 118 | ||
119 | local N=999999999 | 119 | local N=999999999 |
120 | local lane9= task_launch2(1,N,1) -- huuuuuuge... | 120 | local lane9= task_launch2(1,N,1) -- huuuuuuge... |
@@ -138,7 +138,7 @@ if st=="done" then | |||
138 | end | 138 | end |
139 | assert( st=="running" ) | 139 | assert( st=="running" ) |
140 | 140 | ||
141 | lane9:cancel() | 141 | lane9:cancel( "count", 100) -- 0 timeout, 100 instructions count hook |
142 | 142 | ||
143 | local t0= os.time() | 143 | local t0= os.time() |
144 | while os.time()-t0 < 5 do | 144 | while os.time()-t0 < 5 do |
@@ -166,7 +166,7 @@ end | |||
166 | local wait_send_lane = lanes.gen( "*", wait_send)() | 166 | local wait_send_lane = lanes.gen( "*", wait_send)() |
167 | repeat until wait_send_lane.status == "waiting" | 167 | repeat until wait_send_lane.status == "waiting" |
168 | print "wait_send_lane is waiting" | 168 | print "wait_send_lane is waiting" |
169 | wait_send_lane:cancel() | 169 | wait_send_lane:cancel() -- hard cancel, 0 timeout |
170 | repeat until wait_send_lane.status == "cancelled" | 170 | repeat until wait_send_lane.status == "cancelled" |
171 | print "wait_send_lane is cancelled" | 171 | print "wait_send_lane is cancelled" |
172 | --################################################]] | 172 | --################################################]] |
@@ -179,7 +179,7 @@ end | |||
179 | local wait_receive_lane = lanes.gen( "*", wait_receive)() | 179 | local wait_receive_lane = lanes.gen( "*", wait_receive)() |
180 | repeat until wait_receive_lane.status == "waiting" | 180 | repeat until wait_receive_lane.status == "waiting" |
181 | print "wait_receive_lane is waiting" | 181 | print "wait_receive_lane is waiting" |
182 | wait_receive_lane:cancel() | 182 | wait_receive_lane:cancel() -- hard cancel, 0 timeout |
183 | repeat until wait_receive_lane.status == "cancelled" | 183 | repeat until wait_receive_lane.status == "cancelled" |
184 | print "wait_receive_lane is cancelled" | 184 | print "wait_receive_lane is cancelled" |
185 | --################################################]] | 185 | --################################################]] |
@@ -192,7 +192,7 @@ end | |||
192 | local wait_receive_batched_lane = lanes.gen( "*", wait_receive_batched)() | 192 | local wait_receive_batched_lane = lanes.gen( "*", wait_receive_batched)() |
193 | repeat until wait_receive_batched_lane.status == "waiting" | 193 | repeat until wait_receive_batched_lane.status == "waiting" |
194 | print "wait_receive_batched_lane is waiting" | 194 | print "wait_receive_batched_lane is waiting" |
195 | wait_receive_batched_lane:cancel() | 195 | wait_receive_batched_lane:cancel() -- hard cancel, 0 timeout |
196 | repeat until wait_receive_batched_lane.status == "cancelled" | 196 | repeat until wait_receive_batched_lane.status == "cancelled" |
197 | print "wait_receive_batched_lane is cancelled" | 197 | print "wait_receive_batched_lane is cancelled" |
198 | --################################################]] | 198 | --################################################]] |