def test_simple_concurrency():
 pool = make_pool(1, 1)
 for i in range(3):
  pool.put(FakeTarPartition(1))
 pool.join()

def test_simple_concurrency ( ) : pool = make_pool ( 1 , 1 ) for i in range ( 3 ) : pool . put ( FakeTarPartition ( 1 ) ) pool . join ( )
try a pool that cannot execute all submitted jobs at once .