def test_concurrency(self):
client = FakePooledThriftClientMixin(host_provider=HostsProvider(HOSTS),
pool_size=5)
self.assertEqual(0, AnotherFakeClient.in_flight_calls)
AnotherFakeClient.num_calls = 0
greenlets = []
for i in xrange(0, 10):
greenlets.append(gevent.spawn(self._run_method_success,
client, 3))
gevent.joinall(greenlets)
self.assertEqual(30, AnotherFakeClient.num_calls)
评论列表
文章目录