/ / AttributeError: l'oggetto 'Queue' non ha attributo 'join' in python 2.7.x - python, python-2.7, python-multithreading

AttributeError: l'oggetto 'Queue' non ha attributo 'join' in python 2.7.x - python, python-2.7, python-multithreading

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 № 1

multiprocessing.Queue è l'oggetto sbagliato Tu vuoi Queue.Queue, cioè

import Queue
q = Queue.Queue()