Script execution
This commit is contained in:
40
script/parallel.py
Normal file
40
script/parallel.py
Normal file
@@ -0,0 +1,40 @@
|
||||
#1. Example parallelizeing
|
||||
|
||||
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,)))
|
||||
|
||||
|
||||
#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,)))
|
||||
Reference in New Issue
Block a user