#!/usr/bin/env python

# coding: utf-8

"""

This demo creates multiple processes of Producers to spam a socketcan bus.

"""

import time

import logging

import concurrent.futures

import can

def producer(id):

""":param id: Spam the bus with messages including the data id."""

bus = can.interface.Bus(bustype='socketcan', channel='vcan0')

for i in range(16):

msg = can.Message(arbitration_id=0x0cf02200+id, data=[id, i, 0, 1, 3, 1, 4, 1])

bus.send(msg)

# TODO Issue #3: Need to keep running to ensure the writing threads stay alive. ?

time.sleep(2)

if __name__ == "__main__":

#logging.getLogger('').setLevel(logging.DEBUG)

with concurrent.futures.ProcessPoolExecutor(max_workers=4) as executor:

executor.map(producer, range(5))

time.sleep(2)