diff --git a/script/mytest/parallel.py b/script/mytest/parallel.py new file mode 100644 index 0000000..da4255e --- /dev/null +++ b/script/mytest/parallel.py @@ -0,0 +1,41 @@ +#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,))) \ No newline at end of file diff --git a/script/mytest/test-time.py b/script/mytest/test-time.py new file mode 100644 index 0000000..2a39b33 --- /dev/null +++ b/script/mytest/test-time.py @@ -0,0 +1,77 @@ + +import datetime +import time + +def now(): + return datetime.datetime.now() + +# Prints one of the following formats*: +# 1.58 days +# 2.98 hours +# 9.28 minutes # Not actually added yet, oops. +# 5.60 seconds +# 790 milliseconds +# *Except I prefer abbreviated formats, so I print d,h,m,s, or ms. +def format_delta(start,end): + + # Time in microseconds + one_day = 86400000000 + one_hour = 3600000000 + one_second = 1000000 + one_millisecond = 1000 + + delta = end - start + + build_time_us = delta.microseconds + delta.seconds * one_second + delta.days * one_day + + days = 0 + while build_time_us > one_day: + build_time_us -= one_day + days += 1 + + if days > 0: + time_str = "%.2fd" % ( days + build_time_us / float(one_day) ) + else: + hours = 0 + while build_time_us > one_hour: + build_time_us -= one_hour + hours += 1 + if hours > 0: + time_str = "%.2fh" % ( hours + build_time_us / float(one_hour) ) + else: + seconds = 0 + while build_time_us > one_second: + build_time_us -= one_second + seconds += 1 + if seconds > 0: + time_str = "%.2fs" % ( seconds + build_time_us / float(one_second) ) + else: + ms = 0 + while build_time_us > one_millisecond: + build_time_us -= one_millisecond + ms += 1 + time_str = "%.2fms" % ( ms + build_time_us / float(one_millisecond) ) + print time_str; + return time_str + +# returns the elapsed milliseconds since the start of the program +def millis(): + dt = datetime.now() - start_time + ms = (dt.days * 24 * 60 * 60 + dt.seconds) * 1000 + dt.microseconds / 1000.0 + return ms +#d = datetime.now() +#print "datetime.now", d +def TimestampMillisec64(): + return int((datetime.datetime.utcnow() - datetime.datetime(1970, 1, 1)).total_seconds() * 1000) + +now(); +#format_delta(1496394245,1596400000); +ticks = time.time() +print "Number of ticks since 12:00am, January 1, 1970:", ticks +#print time_str; +localtime = time.asctime( time.localtime(time.time()) ) +print "Local current time :", localtime + +from datetime import datetime +dt = datetime.now() +print "datetime.now", dt diff --git a/script/mytest/test1.py b/script/mytest/test1.py new file mode 100644 index 0000000..cae1d08 --- /dev/null +++ b/script/mytest/test1.py @@ -0,0 +1,16 @@ +#rel_x = pico_bpm6_new_x.read() +rel_x = pico_bpm6_ts_x.read() + +class SensorXAxis(ReadableArray): + def __init__(self, sensor): + self.sensor = sensor + def read(self): + return [x + self.sensor.getTimestamp() for x in rel_x] + def getSize(self): + return len(rel_x) #only reads if cache is None + + +x_axis = SensorXAxis(pico_bpm6_ts_sumall) + +#plot(x_axis.read()) +plot(x_axis) \ No newline at end of file