Multi threaded map

gistfile1.py

from multiprocessing import Process, Queue                                         
                                                                                   
                                                                                   
def mp_map(pfunc, iterable, debug=False):                                          
                                                                                   
    q = Queue(2)                                                                   
                                                                                   
    for i, u in enumerate(iterable):                                               
        t = Process(target=lambda q, i, u: q.put([i,                               
                                                  pfunc(u)]), args=(q, i, u))   
        t.start()                                                                  
                                                                                   
    results = list()                                                               
    while len(results) < len(iterable):                                            
        res = q.get()                                                              
        results.append(res)                                                        
        if debug:                                                                  
            print 'worker %d completed' % res[0]                                   
                                                                                   
    return [x for (_, x) in sorted(results)]