use threads instead of processes

This commit is contained in:
Alexey Lavrenuke (load testing) 2014-05-28 18:21:01 +04:00
parent a0422a1861
commit e3a6b0c062

View File

@ -116,7 +116,7 @@ class BFGShooter(object):
def _worker(self):
self.log.info("Started shooter process with %s threads..." % self.threads)
pool = [mp.Process(target=self._thread_worker) for i in xrange(0, self.threads)]
pool = [th.Thread(target=self._thread_worker) for i in xrange(0, self.threads)]
map(lambda x: x.start(), pool)
map(lambda x: x.join(), pool)
self.log.info("Exiting shooter process...")