Simple Thread Pool Execution in Python

dummy_pool.py

#!/usr/bin/env python -u

import itertools
import sys
import time
import thread
import threading
import random
from multiprocessing.dummy import Pool as ThreadPool

class DummyThreadPool(object):
    def __init__(self, num_threads=1):
        self.pool = ThreadPool(num_threads)
        self.results = None

    def submit(self, func, data):
        return self.pool.map(func, data)

    def wait(self):
        self.pool.close()
        self.pool.join()




# Usage
def do_work(arg):
    thread_id = thread.get_ident()
    print '{} is starting work on {}'.format(thread_id, arg)
    time.sleep(random.randint(1,10))
    print '{} is done working on {}'.format(thread_id, arg)
    return arg*2

pool = DummyThreadPool(15)
results = pool.submit(do_work, range(1,20))
pool.wait()
print results