code: def mthread_submit(nslave, worker_args, worker_envs):
             
      procs = {}
      for i in range(nslave):
          procs[i] = Thread(target = exec_cmd, args = (args.command + worker_args, i, worker_envs))
          procs[i].daemon = True
          procs[i].start()
      for i in range(nslave):
          procs[i].join()
docs: customized submit script, that submit nslave jobs, each must contain args as parameter
        note this can be a lambda function containing additional parameters in input
        Parameters
           nslave number of slave process to start up
           args arguments to launch each job
                this usually includes the parameters of master_uri and parameters passed into submit