AttributeError：“队列”对象在python 2.7.x中没有属性“ join”

Question

import multiprocessing
q = multiprocessing.Queue() 

def create_jobs():
    for link in file_to_set(QUEUE_FILE):
        q.put(link)
    q.join() **#here i'm getting Attribute Error**
    crawl()

（这不是完整的代码段。但是我的函数仅在此处给出错误。）

Answer 1

multiprocessing.Queue是错误的对象。您想要Queue.Queue，即：

import Queue
q = Queue.Queue()