code: def push_job(self, fun, *args, **kwargs):
          
          assert callable(fun)
          return self.put((fun, args, kwargs), block=True)
docs: put job if possible, non-blocking
          :param fun:
          :param args:
          :param kwargs:
          :return: