1 import time 2 3 print "--SELFTEST-- loading test" 4 5 us = [ '127.0.0.1#P1', '127.0.0.1#P2' ] 6 7 def payload1(): 8 print "--STEPTEST-- payload1 start" 9 10 b = job.barrier('127.0.0.1#P1', 'here', 45) 11 b.rendezvous(*us) 12 13 print "--STEPTEST-- payload1 complete" 14 15 def payload2(): 16 print "--STEPTEST-- payload2 start" 17 18 time.sleep(5) 19 b = job.barrier('127.0.0.1#P2', 'here', 40) 20 b.rendezvous(*us) 21 22 time.sleep(1) 23 print "--STEPTEST-- payload2 complete" 24 25 job.parallel([payload1], [payload2]) 26
