Multiprocessing queue with Ctrl-C interrupt

multi.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

from multiprocessing import Pool
import signal

def init_worker():
    signal.signal(signal.SIGINT, signal.SIG_IGN)
    
def run(i):
    # ...

if __name__ == '__main__':
    pool = Pool(3, init_worker)
    try:
        results = []
        for idx in xrange(100):
            results.append(pool.apply_async(run, (idx)))
        while len(results) > 0:
            result = results.pop(0)
            result.get()  
        pool.close()
        pool.join()
    except KeyboardInterrupt:
        print "Caught KeyboardInterrupt, terminating workers"
        pool.terminate()
        pool.join()
    print "done"