Method submitCmdsAndWait

tools/marvin/marvin/asyncJobMgr.py:216–228

put commands into a queue at first, then start workers numbers threads to execute this commands

(self, cmds, workers=10)

        return asyncJobResult

    def submitCmdsAndWait(self, cmds, workers=10):
        '''
            put commands into a queue at first, then start workers numbers
            threads to execute this commands
        '''
        self.submitCmds(cmds)
        lock = threading.Lock()
        for i in range(workers):
            worker = workThread(self.inqueue, self.outqueue, self.apiClient,
                                self.db, lock)
            worker.start()

        return self.waitForComplete(workers)

    def submitJobExecuteNtimes(self, job, ntimes=1, nums_threads=1,
                               interval=1):