apw | 89beac3 | 2006-09-25 22:06:10 +0000 | [diff] [blame] | 1 | import time |
2 | import random | ||||
3 | |||||
4 | print "--SELFTEST-- loading test" | ||||
5 | |||||
6 | max = 40 | ||||
7 | |||||
8 | def payload1(id): | ||||
9 | print "--STEPTEST-- payload1 start" | ||||
10 | |||||
11 | time.sleep(random.randint(1, 5)) | ||||
12 | |||||
13 | b = job.barrier('127.0.0.1#P%d' % (id), 'here', 60) | ||||
14 | b.rendevous(*us) | ||||
15 | |||||
16 | print "--STEPTEST-- payload1 complete" | ||||
17 | |||||
18 | us = [] | ||||
19 | jobs = [] | ||||
20 | for n in range(1, max+1): | ||||
21 | us.append('127.0.0.1#P%d' % (n)) | ||||
22 | jobs.append([payload1, n]) | ||||
23 | |||||
24 | job.parallel(*jobs) |