2017-07-29 41 views
1
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() 

没有属性“加入”(这是不是整个代码片段,但我的函数只在这里给出了错误。)AttributeError的:“队列”对象在蟒蛇2.7.x

回答

2

multiprocessing.Queue是错了对象。您需要Queue.Queue,即:

import Queue 
q = Queue.Queue() 
+0

谢谢@Alex Hall –