The example looks correct to me.  Have you tested it and seen it hang?

The q.join() is done, and returns once all the puts have been processed.  *Then* None is put for each worker, which terminates the worker thread.  There's no q.join() to block at that point.