eclipse-paho / eclipse-paho/paho.mqtt.python
Multiprocessing and version 1.2
Open
Status: Available
Type: Enhancement
- Dominant language
- Python
- Stars
- 2.4k
- Forks
- 742
- Avg merge
- 12d 48m
- Merged PRs (30d)
- 1
Description
I've noticed that in version 1.2 each mqtt message now has a thread lock associated with it, which means that it's impossible to add a message to a multiprocessing queue. The project I'm using this for has to use multiprocessing, so I've changed this in my own fork so that there just isn't a lock because I'm never accessing messages in a way that would cause a data race.
It would be better if there was some way to specify whether to use threading locks or multiprocessing locks for messages.
Contributor guide
Assessment
This issue has not been assessed yet.