python sqs multithread

push_sqs.py

from threading import Thread
from Queue import Queue

import boto.sqs
from boto.sqs.message import RawMessage

sqs = boto.sqs.connect_to_region('ap-northeast-1')
queue = sqs.get_queue('queue-name')

q = Queue()

for i in user_id_list:
    q.put(i)

THREADS = 20

def doWork(q):
    while True:
        user_id = q.get()
        
        if user_id is None:
            break
            
        msg = RawMessage()
        msg.set_body(json.dumps({
            'target': user_id,
        }))
        queue.write(msg)
        

for i in range(THREADS):
    t = Thread(target=doWork, args=(q, ))
    q.put(None) # for stop while
    t.start()