ebroecker
diff --git a/‎examples/virtual_can_demo.py‎
Lines changed: 8 additions & 6 deletions b/‎examples/virtual_can_demo.py‎
Lines changed: 8 additions & 6 deletions
@@ -2,7 +2,7 @@
 # coding: utf-8
 
 """
-This demo creates multiple processes of Producers to spam a socketcan bus.
+This demo creates multiple processes of producers to spam a socketcan bus.
 """
 
 from time import sleep
@@ -11,19 +11,21 @@
 import can
 
 
-def producer(id):
+def producer(id, message_count=16):
     """Spam the bus with messages including the data id.
+
     :param int id: the id of the thread/process
     """
 
-    with can.ThreadSafeBus(bustype='socketcan', channel='vcan0') as bus:
-        for i in range(16):
+    with can.Bus(bustype='socketcan', channel='vcan0') as bus:
+        for i in range(message_count):
             msg = can.Message(arbitration_id=0x0cf02200+id, data=[id, i, 0, 1, 3, 1, 4, 1])
             bus.send(msg)
         sleep(1.0)
 
+    print("Producer #{} finished sending {} messages".format(id, message_count))
+
+
 if __name__ == "__main__":
     with ProcessPoolExecutor(max_workers=4) as executor:
         executor.map(producer, range(5))
-
-sleep(1.0)