| 67 |
| 68 |
| 69 |
| 70 |
| 71 |
| 72 |
| 73 |
| 74 |
| 75 |
| 76 |
| 77 | |
def test_join_timeout(): |
-> pool = WorkerPool() |
q = py.std.Queue.Queue() |
def f(): |
q.get() |
reply = pool.dispatch(f) |
pool.shutdown() |
py.test.raises(IOError, pool.join, 0.01) |
q.put(None) |
reply.get(timeout=1.0) |
pool.join(timeout=0.1) | |
