parameters: (self, input, threads=5, queue=None, name=None)
return_statement: return self.channel(workers, format=format_of(input))
docstring: Parallelize input messages over thread worker pool.
docstring_summary: Parallelize input messages over thread worker pool.
docstring_tokens: Parallelize input messages over thread worker pool .
function: def parallel(self, input, threads=5, queue=None, name=None):
      """Parallelize input messages over thread worker pool."""
      workers = self.task("workers", name=name)
      workers.add_param("worker_threads", threads)
      if queue != None: workers.add_param("queue_size", queue)
      self.connect(input, workers)
      return self.channel(workers, format=format_of(input))
function_tokens: def parallel ( self , input , threads = 5 , queue = None , name = None ) : workers = self . task ( "workers" , name = name ) workers . add_param ( "worker_threads" , threads ) if queue != None : workers . add_param ( "queue_size" , queue ) self . connect ( input , workers ) return self . channel ( workers , format = format_of ( input ) )