Python线程没有执行创建的所有线程

Question

我有一个python脚本，所以我在python中使用线程模块并发执行。

class check_bl(threading.Thread):
    def __init__(self, ip_client, reverse_ip, key, value):
        threading.Thread.__init__(self)
        self.ip_client = ip_client
        self.reverse_ip = reverse_ip
        self.key = key
        self.value = value

def run（self）：db=MySQLdb。connect（'localhost'，'mytable'，'user'，'mytable'）游标=db。cursor（）query=“dig short”str（反向ip）”按键try:output=子进程。检查\u输出（查询，shell=True）输出\u编辑=输出。条带（）除外：输出\u edited=“发生超时”

    if output_edited in value:
        try:
            cursor.execute() # execute INSERT command
            db.commit()
        except:
            db.rollback()
        db.close()
    else:
        try:
            cursor.execute() # execute INSERT command
            db.commit()
        except:
            db.rollback()
        db.close()

对于IPNetwork（range_ip_client）中的ip_client：ip_client=......reverse_ip=...

for key, value in my_dictionary.items():
    myThread = check_bl(ip_client, reverse_ip, key, value)
    myThread.start()
    threadList.append(myThread)

for t in threadList:
t.join()

问题是my_dictionary中的每个键、值都没有执行（没有插入到数据库，尽管某些键、值执行了多次）。我的字典有30个条目，但只有10-20个条目可以执行。如果我像下面的2个例子那样插入join（），我的所有字典项（）都会执行，但同时只执行一个线程。如果创建的每个线程都有问题，那么它将创建一个数据库连接。所以数据库无法处理它。

for key, value in my_dictionary.items():
    myThread = check_bl(ip_client, reverse_ip, key, value)
    myThread.start()
    threadList.append(myThread)

for t in threadList:
    t.join()

或者

for key, value in my_dictionary.items():
    myThread = check_bl(ip_client, reverse_ip, key, value)
    myThread.start()
    t.join()

谢谢Dksj，我的问题解决了。也许类方法有问题，只需要定义一个函数。

def check_bl(ip_client, reverse_ip, key, value):
    db = MySQLdb.connect('localhost', 'mytable', 'user', 'mytable')
    cursor = db.cursor()
    query = "dig +short " + str(reverse_ip) + "." + key
    try:
        output = subprocess.check_output(query, shell=True)
        output_edited = output.strip()
    except:
        output_edited = "Timeout occured"

    if output_edited in value:
        try:
            cursor.execute() # execute INSERT command
            db.commit()
        except:
            db.rollback()
        db.close()
    else:
        try:
            cursor.execute() # execute INSERT command
            db.commit()
        except:
            db.rollback()
        db.close()

for ip_client in IPNetwork(range_ip_client):
    ip_client = ....
    reverse_ip = ...
    for key, value in my_dictionary.items():
        myThread = check_bl(ip_client, reverse_ip, key, value)
        threadList.append(myThread)

[t.start() for t in threadList]

[t.join() for t in threadList]

Answer 1

我的问题与你的略有不同，我没有使用类方法，我只是根据我的代码修改了你的代码，你可以试试。这个链接帮助我解决了我的问题：如何在Python中使用线程？

def check_bl（ip_客户端、反向ip、密钥、值）：。。。。

threads []
 for key, value in my_dictionary.items():
    # Instantiates the thread
    myThread = Thread( target=check_bl, args=(ip_client, reverse_ip, key, value) )
    #add thread to list 
    threads.append(myThread)

[th.start() for th in threads]
#Join all the threads to make sure the parent waits for all of them to finish
[th.join() for th in threads]