thread_safe_bus.state (getter) should not use locks

Offen

#1,891 erstellt am 07.11.2024 0 Kommentare 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen

Dieses Issue hat noch niemand übernommen.

Bewertung

Schwierigkeit: 4/5
Geschätzter Aufwand: 3-5 Tage
Anfängerfreundlichkeit: 35/100

Issue-Typ: Bug
Klarheit: Größtenteils klar
Aktivitätsstatus: Veraltet
Tech-Stack: python
Bereich: networking

Rechercherichtung

Lies zunächst thread_safe_bus.py und die im Issue gezeigte state-Eigenschaft und verfolge dann, wie die send- und receive-Sperren vom thread-safe bus verwendet werden. Bestimme, ob state-Lesevorgänge unabhängig von diesen Sperren eine Synchronisierung erfordern; abgeschlossen ist die Aufgabe, wenn state-Prüfungen nicht mehr auf den Listener warten, während sie bei gleichzeitig ausgeführten send- und receive-Operationen sicher bleiben.

Vom Indexierungsmodell aus dem Issue-Text verfasst.

Beschreibung

enhancement

Problem description

I have a small application that listens on one thread, and may send on another (using asyncio). Before sending, I used to check the hardware state by evaluating the .state property. I use the thread safe bus.
However, this leads to long wait phases, depending on incoming messages.

It turns out that getting the .state property locks both send and receive locks, whereas lock_recv is probably occupied by the listener most of the time, which causes the delays.
in thread_safe_bus.py:

    @property
    def state(self):
        with self._lock_send, self._lock_recv:
            return self.__wrapped__.state

Proposed change

I am not very familiar with thread-safe communication in Python, but derived from my C++ knowledge, the value of the .state property is only an enum value and should be atomic anyway, especially when reading.
So from my point of view, I would either just return the value without locks. Or - if any locking is needed for some reason - use a separate state-access-lock that is independent from lock_send and lock_recv.

Workaround

I guess checking the bus state before each send() call is not the correct way to do. I switched to a mere send() and catch a CanError exception afterwards, which works fine without delay.

Vorherrschende Sprache: Python
Sterne: 1.6k
Forks: 697
PR-Merge-Kennzahlen: Keine gemergten PRs in 30 T.

Beitragsleitfaden

Beitragsleitfaden öffnen

Erste Schritte

Lesen Sie das ganze Issue und danach den Beitragsleitfaden des Projekts.
Schreiben Sie ins Issue, dass Sie es übernehmen — das erspart doppelte Arbeit.
Forken Sie das Repository und arbeiten Sie in einem Branch.
Öffnen Sie einen Pull Request, der die Issue-Nummer nennt.

Mehr aus hardbyte/python-can

IXXAT: timestamps read 1.5 x wall time plus adapter uptime (misplaced parenthesis in _timeoffset; start tick never captured in vcinpl2) Offen

Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 88/100

hardbyte/python-can#2103 · Erstellt am 18.9.2026
Unhashable type for Systec interface errors Offen

bug

Schwierigkeit 1/5 Unter einer Stunde Anfängerfreundlichkeit 78/100

hardbyte/python-can#2077 · 1 Kommentar · 1 Reaktion · Erstellt am 13.7.2026
New error behaviour when calling `flush_tx_buffer` for several interface types Offen

bug

Schwierigkeit 1/5 Unter einer Stunde Anfängerfreundlichkeit 68/100

hardbyte/python-can#1922 · 1 Reaktion · Erstellt am 22.2.2025
Add support for the more efficient ElmüSoft Candlelight Protocol Offen

enhancement

Schwierigkeit 5/5 Über eine Woche Anfängerfreundlichkeit 30/100

hardbyte/python-can#2102 · Erstellt am 15.9.2026
PCAN message timestamps drift after macOS system sleep Offen

bug

Schwierigkeit 3/5 1-2 Tage Anfängerfreundlichkeit 68/100

hardbyte/python-can#2092 · Erstellt am 21.8.2026

Alle Issues in hardbyte/python-can