我有一个带有 queue
表的数据库,新条目在队列中不断插入。
我想要一个 Python 脚本尽可能快地执行队列,我认为我需要一些线程化的代码来作为守护进程运行。
但是我不知道如何将数据库用作队列。
我正在查看这个示例:
import MySQLdb
from Queue import Queue
from threading import Thread
def do_stuff(q):
while True:
print q.get()
q.task_done()
q = Queue(maxsize=0)
num_threads = 10
for i in range(num_threads):
worker = Thread(target=do_stuff, args=(q,))
worker.setDaemon(True)
worker.start()
// TODO: Use the DB
db = MySQLdb.connect(...)
cursor = db.cursor()
q = cursor.execute("SELECT * FROM queue")
for x in range(100):
q.put(x)
q.join()