|
cut 3.3.0
|
Starts additional thread that dispatches received data and pushes new value events with a given interval to avoid processing of all received samples (which causes an overload). More...
Public Member Functions | |
| change_throttling_rate (self, new_value) | |
| Sets new value of throttling rate. | |
| run (self) | |
| Run throttling mechanism Retrieve current throttling_timeout (in case it's been changed). | |
Starts additional thread that dispatches received data and pushes new value events with a given interval to avoid processing of all received samples (which causes an overload).
| taurusmalps.taurusmalpsattribute.DispatcherThread.run | ( | self | ) |
Run throttling mechanism Retrieve current throttling_timeout (in case it's been changed).
Retrieve the most recent data from queue in TaurusMalPSAttribute. If the data exist push new data event, clear the queue and sleep for an amount of seconds defined by throttling rate.