Files
x12sa/script/mytest/parallel.py
2017-08-11 09:36:34 +02:00

41 lines
1.6 KiB
Python

#1. Example parallelizeing
prefix="X12SA-OP-BPM6:";
def f2(c, v):
print "Running ", c, " = " , v
def init_mod_par(prefix):
cmd = "Erase/Start"
parallelize((f2,(prefix + "Current1:TSControl",cmd)), \
(f2,(prefix + "Current2:TSControl",cmd)), \
(f2,(prefix + "Current3:TSControl",cmd)), \
(f2,(prefix + "Current4:TSControl",cmd)) )
ret = parallelize((init_mod_par,("T1",)), (init_mod_par,("T2",)), (init_mod_par,("T3",)))
#2. Parllelizing multiple modules with sequential init
def init_module(prefix):
start = time.time()
caputq(prefix + "Current1:TSControl", "Erase/Start")
caputq(prefix + "Current2:TSControl", "Erase/Start")
caputq(prefix + "Current3:TSControl", "Erase/Start")
caputq(prefix + "Current4:TSControl", "Erase/Start")
print "Execution time = " + str(time.time() - start)
init_module(pico_amp.prefix)
#ret = parallelize((init_module,(pico_amp.prefix,)), (init_module,(pico_amp2.prefix,)), (init_module,(pico_amp3.prefix,)))
ret = parallelize((init_module,(pico_amp.prefix,)), (init_module,(pico_amp3.prefix,)))
#3,Parllelizing multiple modules with parallel init
def init_mod_par(prefix):
cmd = "Erase/Start"
parallelize( (caputq,(prefix + "Current1:TSControl",cmd)), \
(caputq,(prefix + "Current2:TSControl",cmd)), \
(caputq,(prefix + "Current3:TSControl",cmd)), \
(caputq,(prefix + "Current4:TSControl",cmd)) )
ret = parallelize((init_mod_par,(pico_amp.prefix,)), (init_mod_par,(pico_amp2.prefix,)), (init_mod_par,(pico_amp3.prefix,)))