Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def services():
- services = [method1(),
- method2(),
- method3(),
- mrthod4(),
- method5()]
- return services
- def runAll():
- import subprocess
- for i in services():
- proc = subprocess.call(i,shell=True)
- from joblib import Parallel, delayed
- functions = [fn1, fn2, fn3, fn4]
- results = Parallel(n_jobs=4)(delayed(f)() for f in functions)
- subprocess.call("./foo1&", shell=True)
- subprocess.call("./foo2&", shell=True)
- from multiprocessing import Process
- def f1():
- while True:
- print 'foo'
- def f2():
- while True:
- print 'bar'
- def f3():
- while True:
- print 'baz'
- if __name__ == '__main__':
- for func in (f1, f2, f3):
- Process(target=func).start()
- from multiprocessing import Pool
- def parallelfuncs(funcs, args, results, bad_value = None):
- p = Pool()
- waiters = []
- for f in funcs:
- waiters.append(p.apply_async(f, args, callback = results.append))
- p.close()
- for w in waiters:
- if w.get()[0] == bad_value:
- p.terminate()
- return p
- results = []
- parallelfuncs(services, args, results).join()
- print results
Add Comment
Please, Sign In to add comment