自己的线程池

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

import threading
import Queue
import time

class ThreadPool(object):
    def __init__(self,max_num=20):
        self.q = Queue.Queue(max_num)
        for i in xrange(max_num):
            self.q.put(threading.Thread)   // 这里往队列中加入的是类，不是对象
    #从线程池中取一个线程
    def get_thread(self):
        return self.q.get()

    #向线程池中添加一个线程
    def put_thread(self):
        self.q.put(threading.Thread)

Pool = ThreadPool(5)

def run(n,pool):
    print n
    time.sleep(2)
    pool.put_thread()

for i in xrange(10):
    thread = Pool.get_thread()
    t = thread(target = run,args=(i,Pool))
    t.start()