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) | |