Таким образом, в основном моя цель состоит в том, чтобы запускать и продолжать запускать поток для каждого из моих handlerId. В моем основном потоке у меня есть следующий код:
handlerId = rcvd_dict['handlerId']
if handlerId not in thread_dict: #start a new thread, storing it in thread_dict
new_thread = threading.Thread(target = request_thread(ws, rcvd_dict))
thread_dict[handlerId] = new_thread
thread_dict[handlerId].start()
else: #return to the specific thread already existing also passing the argument
'rcvd_dict' that is a dictionary with information for the thread to run
Каждый поток начинает выполнять следующую функцию:
def request_thread(ws, rcvd_dict):
#do something with the dictionary 'rcvd_dict' received as argument
Я хочу поддерживать один и тот же поток, который может несколько раз получать словарь, чтобы он мог что-то с ним делать.Я хочу сделать поток "спящим" после одного выполнения и возобновить / возобновить его выполнение только после того, как я хочу вызвать его снова с другим аргументом словаря 'rcvd_dict'.Я думал о цикле в функции потока, но как определить условие между основным потоком и каждым подпотоком?Легко ли это сделать в Python?