I'm facing with a "little" problem regarding adding data to queue.Queue from a thread.
Environment data: Ubuntu 18.04 / Python 3.6.7 / Python 3.8.5
In the rows below I will post my simplified code. Any help will be appreciated.
from threading import Thread,Lock
from queue import Queue
from random import randint
thread = None
thread_lock = Lock()
q = Queue()
def worker(number):
random_number= [str(randint(1,999)),number]
q.put(random_number)
def first_function(iteration):
global thread
some_list=[]
with thread_lock:
threads=[]
if thread is None:
for iterator in range(iteration):
thread = Thread(target=worker,args=(iterator,))
threads.append(thread)
thread.start()
for thread_ in threads:
thread_.join()
thread = None
while not q.empty():
some_list.append(q.get())
return (some_list)
print(first_function(10))
print(first_function(5))
My second call will return an empty list. Please give me an idea .
The problem is with "thread = None" after the method is executed first time on thread is append an <Thread ... > and in second call when you verify "if thread is None", suprize is not None.