code: def broadcast(self, fcn, args):
          
          results = self.map(_lockstep_fcn, [(len(self), fcn, args)] * len(self))
          _numdone.value = 0
          return results
docs: Do a function call on every worker.
  
          Parameters
          ----------
          fcn: funtion
              Function to call.
          args: tuple
              The arguments for Pool.map