def test_maxthreads():
pool = WorkerPool(maxthreads=1)
def f():
py.std.time.sleep(0.5)
try:
pool.dispatch(f)
py.test.raises(IOError, pool.dispatch, f)
finally:
-> pool.shutdown()