change the workers on the master top use threading

This commit is contained in:
Thomas S Hatch 2011-03-03 13:38:13 -07:00
parent f9e27a2c42
commit 2ec3a6c873

View File

@ -106,7 +106,7 @@ class ReqServer(multiprocessing.Process):
self.workers.bind(self.w_uri)
for ind in range(int(self.num_threads)):
proc = multiprocessing.Process(target=self.__worker)
proc = threading.Thread(target=self.__worker)
proc.start()
zmq.device(zmq.QUEUE, self.clients, self.workers)