MCPcopy Create free account
hub / github.com/brmmm3/fastthreadpool / cancel

Method cancel

fastthreadpool/fastthreadpool.py:834–871  ·  view source on GitHub ↗
(self, job_id=None, timer=None)

Source from the content-addressed store, hash-verified

832 self._scheduled.clear()
833
834 def cancel(self, job_id=None, timer=None):
835 if timer is True:
836 self._delayed_cancel()
837 self._scheduled_cancel()
838 elif isinstance(timer, TimerObj):
839 try:
840 timer.timer_id.cancel()
841 self._scheduled.remove(timer.timer_id)
842 except ValueError:
843 pass
844 try:
845 timer.old_timer_id.cancel()
846 self._scheduled.remove(timer.old_timer_id)
847 except ValueError:
848 pass
849 elif timer is not None:
850 timer.cancel()
851 try:
852 self._delayed.remove(timer)
853 except ValueError:
854 pass
855 try:
856 self._scheduled.remove(timer)
857 except ValueError:
858 pass
859 if job_id is False:
860 return True
861 if job_id is None:
862 self._jobs.clear()
863 return True
864 for job in self._jobs:
865 if id(job) == job_id:
866 try:
867 self._jobs.remove(job)
868 return True
869 except ValueError:
870 return False
871 return False

Callers 5

ShutdownFunction · 0.80
_delayed_cancelMethod · 0.80
_scheduled_cancelMethod · 0.80
ex_schedule.pyFile · 0.80
ex_submit_later.pyFile · 0.80

Calls 3

_delayed_cancelMethod · 0.95
_scheduled_cancelMethod · 0.95
clearMethod · 0.80

Tested by

no test coverage detected