Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
def __worker_pool_init(self, pool_size, task_queue_size=100, result_queue_size=1):
self.__task_queue = mp.Queue(task_queue_size)
self.__result_queue = mp.Queue(result_queue_size)
self.__worker_pool = [RSAOracleWorker(self.oracle, self.callback, self.__task_queue, self.__result_queue, self.n, self.e)
for _ in xrange(pool_size)]
self.__logger.info("Created %i workers in the processing pool" % (pool_size))