using multiprocessing

multiproc.py

import multiprocessing as mltp


def work(x, y):
    return x * y


def worker(queue):
    while True:
        args = queue.get()
        if args is None: break
        work(*args)


NPROC = 4
queue = mltp.Queue()
# populate the queue
for pair in zip(range(100), range(100, 200)):
    print pair
    queue.put(pair)

for _ in range(NPROC):
    queue.put(None)


pool = mltp.Pool(processes=NPROC)
pool.map_async(worker, (queue, ) * NPROC)