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

common.SimpleThreadPool.SimpleThreadPool.addTask

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


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))


src/c/o/corunner-1.0.7/corunner/TaskController.py   corunner(Download)
			# None blocking, the queue size is unlimited. This is resonable for the node number can not be too large(ten thousands of?). 
			for snode in self.snodes:
				pool.addTask(ExecuteTask(snode, self.programFile, mainProgram, args, self.config))
			if self.config.reportInterval > 0:
				while True: