multiprocessing/queue

warum das so ist? etwaige programmierfehler bitte ich zu verzeihen，-1，-1):queue.put(j)queue.join()if __name__ == "__main__":main() das script beendet sich jedoch nicht， ich übe/lerne noch. ， queue):Process.__init__(self)self.queue = queuedef run(self):while True:number =queue.get()print "Process started: %s" % numbertime.sleep(random.randint( 1， tach， sondern man muss es mit strg+c abbrechen. hat jemand eine idee， ich versuche daten in eine queue zu packen und diese queue mit hilfe von multiprocessing mit mehreren gleichzeitig laufenden prozessen abzuarbeiten. als beispiel das folgende script: Code: import randomimport sysimport osimport timefrom multiprocessing import Process， JoinableQueuequeue = JoinableQueue()class ProcessHost(Process):def __init__(self， 8 ))print "Process ended: %s" % number#signals to queue job is donequeue.task_done()start = time.time()def main():for i in range(2):p = ProcessHost(queue)p.start()for j in xrange(9，。