Simple Consumer & Queue implementation with python multiprocessing

test.py

# coding: utf-8

import multiprocessing as mp

def loop_a(q):
    while not q.empty():
        print(q.get())

if __name__ == '__main__':
    q1=mp.Queue()
    p1 = mp.Process(target=loop_a,args=(q1,))
    p1.start()

    for k in xrange(1,10):
        q1.put(k)

    q1.close()
    q1.join_thread()
    p1.join()