eclipse-paho / eclipse-paho/paho.mqtt.python

Multiprocessing and version 1.2

Open
#137 3 comments 0 reactions 0 assignees View on GitHub
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

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.