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()
(Questo non è un frammento di codice intero, ma la mia funzione restituisce solo l'errore.)
risposte:
3 per risposta № 1multiprocessing.Queue
è l'oggetto sbagliato Tu vuoi Queue.Queue
, cioè
import Queue
q = Queue.Queue()