Mysql den gelen verilere threading ve Queue oluşturamıyorum?

1

S.a. arkadaşlar,

from queue import Queue
import threading

q = Queue()

anafonksiyon(email,sifre,userid):
    #ana islemler v.s. 

def oku():
    while not q.empty():
        try:
            #print(list(q.queue)
             #burdaki email sifre ve userid değerlerini nası alıp anafonksiyona gönderebilirim bilmiyorum.
            anafonksiyon(email,sifre,userid)
        except:
            pass
      

db = mydb.cursor()
db.execute("SELECT * FROM hesap") 
rows = db.fetchall()
for i in rows:
    
    id = i[0]
    email = i[1]
    sifre = i[2]
    userid = i[3]
    db1 = mydb.cursor()
    db1.execute("SELECT * FROM admin WHERE kadi='"+str(userid)+"'") 
    rows1 = db1.fetchall()
    if len(rows1) >= 1:
        q.put(i)
    else:
        print(" yoookkkkk ",userid)


for i in range(3):
    th1 = threading.Thread(target = oku)
    th1.start()
    time.sleep(10)

Yukarıdaki şekilde çalıştırınca sürekli aynı kullanıcıyı gönderiyor. Ben beceremedim açıkcası. Queue hiç kullanmışlığım yok açıkcası. Yardımcı olursanız sevinirim. Benim amaçım işlemleri 3 thread açıp dahada hızlandırmak amacım.Fakat sürekli aynı kullanıcıyı gönderiyor.

2

Arkadaşlar sorunu çözdüm, kusura bakmayın boşa konu açmış gibi oldum yanlış anlaşımasın lütfen.

def oku():
    
    while not q.empty():
        string = q.get() 
        email = string[1]
        sifre = string[2]
        userid = string[3]
        
        try:
            anafonksiyon(email,sifre,userid)
        except:
            pass

string = q.get() ile ulaşabiliyormuşuz. Öğrenmiş olduk.

1 Beğeni