Did I find the right examples for you? yes no      Crawl my project      Python Jobs

common.SimpleThreadPool.SimpleThreadPool

All Samples(2)  |  Call(2)  |  Derive(0)  |  Import(0)


src/c/o/corunner-1.0.7/corunner/TaskController.py   corunner(Download)
	def execute(self, mainProgram, args):
		startTime = time.time()
		pool = threadpool.SimpleThreadPool(self.config.nWorker)
		try:	
			# None blocking, the queue size is unlimited. This is resonable for the node number can not be too large(ten thousands of?). 


src/c/o/corunner-1.0.7/corunner/FileTransporter.py   corunner(Download)
	def execute(self):
		pool = threadpool.SimpleThreadPool(self.nWorker)
		try:	
			for snode in self.snodes:
				pool.addTask(TransportTask(snode, self.source, self.target, self.isOut, self.divideTarget))