Как справится когда python thread locked?

[Завоеватель]

Ребята, столкнулся с такой проблемой: мой python thread locked и не могу понять, как дальше действовать. Запускаю мультипоточность, и кажется, что один из потокоав заблокировался, и весь процесс стопорится. Кто сталкивался с таким, помогите с примерами кода или идеями, как это можно дебажить и решать?

[admin]

Ждём вас в нашем чате в Телеграмм ==>> @pythoneer_chat

А ТАКЖЕ: Канал о Python, статьи и книги ==>> @pythoneer_ru

[OlegMountain]

Привет! В таких случаях обычно бывает, что один из потоков захватил лок (lock) и не отпускает его. Могу предложить следующее:

import threading

lock = threading.Lock()

def thread_function(name):
    print(f'Thread {name}: starting')
    with lock:
        print(f'Thread {name}: has the lock')
        # здесь какой-то код
        print(f'Thread {name}: releasing the lock')
    print(f'Thread {name}: finishing')

threads = []
for i in range(3):
    t = threading.Thread(target=thread_function, args=(i,))
    threads.append(t)
    t.start()

for t in threads:
    t.join() 

Попробуй добавить такие логи в свой код для лучшего понимания, где именно поток застревает.

[Ольга88]

Привет! В таких случаях обычно бывает, что один из потоков захватил лок (lock) и не отпускает его. Могу предложить следующее:

import threading

lock = threading.Lock()

def thread_function(name):
    print(f'Thread {name}: starting')
    with lock:
        print(f'Thread {name}: has the lock')
        # здесь какой-то код
        print(f'Thread {name}: releasing the lock')
    print(f'Thread {name}: finishing')

threads = []
for i in range(3):
    t = threading.Thread(target=thread_function, args=(i,))
    threads.append(t)
    t.start()

for t in threads:
    t.join() 

Попробуй добавить такие логи в свой код для лучшего понимания, где именно поток застревает.

Полезный пример кода, спасибо! Такие логи реально могут помочь отладить проблему.

[DustRider814]

Если python thread locked это типичноиз-за deadlock. Обычно происходит, когда два потока ждут друг друга, держа при этом ресурсы, которые нужны другому потоку.
Проверь, нет ли циклического ожидания.

[HopeSummers]

Если python thread locked это типичноиз-за deadlock. Обычно происходит, когда два потока ждут друг друга, держа при этом ресурсы, которые нужны другому потоку.
Проверь, нет ли циклического ожидания.

Отлично подмечено, про deadlock сам забываю часто.

[Андрей Валентинович]

Еще один вариант: попробуй использовать threading.Event вместо Lock. В некоторых сценариях это может помочь избежать блокировок.

[FlameWielder482]

Еще один вариант: попробуй использовать threading.Event вместо Lock. В некоторых сценариях это может помочь избежать блокировок.

Интересная идея. Никогда не пробовал заменять Lock на Event.

[Kurban4891]

В твоем случае можно попробовать использовать модуль multiprocessing вместо threading, он лучше работает с python GIL и может помочь с этой проблемой.

[Светлячок]

В твоем случае можно попробовать использовать модуль multiprocessing вместо threading, он лучше работает с python GIL и может помочь с этой проблемой.

Да, multiprocessing правда может помочь, если проблема в GIL.