parameters: (self, x, workers, use_multiprocessing,
                                max_queue_size)
return_statement: return generator_fn
docstring: Create a callable, possibly including an Enqueuer.
docstring_summary: Create a callable, possibly including an Enqueuer.
docstring_tokens: Create a callable possibly including an Enqueuer .
function: def _handle_multiprocessing(self, x, workers, use_multiprocessing,
                                max_queue_size):
      """Create a callable, possibly including an Enqueuer."""
      if workers > 1 or (workers > 0 and use_multiprocessing):
        def generator_fn():
          enqueuer = data_utils.GeneratorEnqueuer(
              x, use_multiprocessing=use_multiprocessing)
          enqueuer.start(workers=workers, max_queue_size=max_queue_size)
          return enqueuer.get()
      else:
        generator_fn = lambda: x
      return generator_fn
function_tokens: def _handle_multiprocessing ( self , x , workers , use_multiprocessing , max_queue_size ) : if workers > 1 or ( workers > 0 and use_multiprocessing ) : def generator_fn ( ) : enqueuer = data_utils . GeneratorEnqueuer ( x , use_multiprocessing = use_multiprocessing ) enqueuer . start ( workers = workers , max_queue_size = max_queue_size ) return enqueuer . get ( ) else : generator_fn = lambda : x return generator_fn