some broken threadpool stuff

gistfile1.py

from paste.httpserver import ThreadPool
pool = ThreadPool(5)

import random
import time

def do_work(t):
    print 'about to sleep for %s sec' %  (t,)
    time.sleep(t)
    print 'slept for %s' %(t)
    return (t, True)


source = [random.random() for x in range(50)]

#def join_all(queue):
#    if queue.qsize()>0:
#        for x in queue:
#            x.join(2)

def go():
    print 'about to block'
    for item in source:
        print item
        pool.add_task(lambda:  do_work(item))

    #join_all(pool.queue)
    #print 'done'
    return pool