wip

serialtimetest/serialtimetest.2.multi.py

@@ -12,8 +12,6 @@
 #import serial,sys,time,signal,multiprocessing
 
 import sys,time,signal,multiprocessing
-evt = multiprocessing.Event()
-val = multiprocessing.Value('i',0)
 
 if (len(sys.argv) != 5):
    print("command line: serialtest.2.multi.py port1 port2 speed delay")
@@ -33,6 +31,10 @@ ports = [port0,port1]
 
 '''
 #
+# event version
+#
+evt = multiprocessing.Event()
+#
 # worker event handler
 #
 def worker(id,evt):
@@ -53,8 +55,18 @@ def handler(signum,stack):
       evt.clear()
    else:
       evt.set()
+#
+# start workers
+#
+p0 = multiprocessing.Process(target=worker,args=(0,evt,))
+p0.start()
+p1 = multiprocessing.Process(target=worker,args=(1,evt,))
+p1.start()
 '''
-
+#
+# Value version
+#
+val = multiprocessing.Value('i',0,lock=False)
 #
 # worker event handler
 #
@@ -72,13 +84,10 @@ def worker(id,val):
 # alarm event handler
 #
 def handler(signum,stack):
-   if (evt.is_set()):
-      evt.clear()
    if (val.value == 0):
       val.value = 1
    else:
       val.value = 0
-
 #
 # start workers
 #
@@ -86,6 +95,7 @@ p0 = multiprocessing.Process(target=worker,args=(0,val,))
 p0.start()
 p1 = multiprocessing.Process(target=worker,args=(1,val,))
 p1.start()
+
 #
 # start alarm
 #