CODEWITHSUNDEEP
pythonmultithreadingqueue
MultiQueue
MultiQueue

Reputation: 21

Threading / Queue in Python

I intend using threads/queues with python 2.5.2 But it seems that python becomes freezed at the queue.join()-command. The output of the followong code is only: BEFORE

import Queue
import threading

queue = Queue.Queue()

class ThreadUrl(threading.Thread):

    def __init__(self, queue):
        threading.Thread.__init__(self)
        self.queue = queue

    def run(self):
        while True:

            i = self.queue.get()
            print i
            self.queue.task_done()


def main():

    for i in range(5):
        t = ThreadUrl(queue)
        t.setDaemon(True)
        t.start()

    for i in range(5):
        queue.put(i)

    print "BEFORE"
    queue.join()
    print "AFTER"


main()

Has someone an idea about what is going wrong?

Upvotes: 2

Views: 2711

Answers (4)

dgg32
dgg32

Reputation: 1457

I think it is the t.setDaemon(True) part.

So in Python > 2.6, use:

t.setDaemon(True)

And in Python < 2.6, use:

t.daemon = True

Upvotes: 1

Muhammad Suleman
Muhammad Suleman

Reputation: 797

Use Daemon=True. That will ensure that your thread exits once the main function is executed.

Upvotes: 0

MultiQueue
MultiQueue

Reputation: 1

The solution I now found is:

Don't use Python 2.5.2! If one uses Python 2.7.2 instead the code above works very well.

Thank you all!

Upvotes: 0

brandx
brandx

Reputation: 1053

You run() method on your ThreadUrl class is indented too far. The thread is never started as a result. If you put the indention of the run method at the same indentation level as init() it'll work fine.

Upvotes: 0

Related Questions