rsudp.p_producer (data producer)¶
Producer(queue, threads, testing=False)¶
Data Producer thread (see Producer-consumer message passing) which receives data from the port and puts it on the queue to be passed to the master consumer (
rsudp.c_consumer.Consumer). The producer also looks for flags in each consumer that indicate whether they are
alive==False. If so, the Producer will quit gracefully and put a TERM message on the queue, which should stop all running consumers.
Distributes queue objects to execute various other tasks: for example, it may be used to populate ObsPy streams for various things like plotting, alert triggers, and ground motion calculation.