gistfile1.py

import threading
import Queue
q = Queue.Queue()

def worker():
    while True:
        msg = q.get(block=True)
        # do stuff with the message

t = threading.Thread(target=worker)
t.setDaemon(True)
t.start()

for msg in redis.listen():
    q.put(msg)