Use time.monotonic() for certain timing operations.

Refs #521

huey/api.py

@@ -34,6 +34,7 @@
 from huey.utils import normalize_time
 from huey.utils import reraise_as
 from huey.utils import string_type
+from huey.utils import time_clock
 from huey.utils import to_timestamp
 
 
@@ -350,15 +351,15 @@ def _execute(self, task, timestamp):
                 self._emit(S.SIGNAL_CANCELED, task)
                 return
 
-        start = time.time()
+        start = time_clock()
         exception = None
         task_value = None
 
         try:
             try:
                 task_value = task.execute()
             finally:
-                duration = time.time() - start
+                duration = time_clock() - start
         except TaskLockedException as exc:
             logger.warning('Task %s not run, unable to acquire lock.', task.id)
             exception = exc
@@ -872,10 +873,10 @@ def get_raw_result(self, blocking=False, timeout=None, backoff=1.15,
             if res is not EmptyData:
                 return res
         else:
-            start = time.time()
+            start = time_clock()
             delay = .1
             while self._result is EmptyData:
-                if timeout and time.time() - start >= timeout:
+                if timeout and time_clock() - start >= timeout:
                     if revoke_on_timeout:
                         self.revoke()
                     raise HueyException('timed out waiting for result')

huey/consumer.py

@@ -21,6 +21,7 @@
 from huey.constants import WORKER_THREAD
 from huey.constants import WORKER_TYPES
 from huey.exceptions import ConfigurationError
+from huey.utils import time_clock
 
 
 class BaseProcess(object):
@@ -167,11 +168,11 @@ def loop(self, now=None):
             current_p = self._next_periodic
             if current_p <= time.time():
                 self._next_periodic += 60
-                self.enqueue_periodic_tasks(now, current)
+                self.enqueue_periodic_tasks(now)
 
         self.sleep_for_interval(current, self.interval)
 
-    def enqueue_periodic_tasks(self, now, start):
+    def enqueue_periodic_tasks(self, now):
         self._logger.debug('Checking periodic tasks')
         for task in self.huey.read_periodic(now):
             self._logger.info('Enqueueing periodic task %s.', task)
@@ -419,7 +420,7 @@ def run(self):
         """
         self.start()
         timeout = self._stop_flag_timeout
-        health_check_ts = time.time()
+        health_check_ts = time_clock()
 
         while True:
             try:
@@ -438,7 +439,7 @@ def run(self):
                 break
 
             if self._health_check:
-                now = time.time()
+                now = time_clock()
                 if now >= health_check_ts + self._health_check_interval:
                     health_check_ts = now
                     self.check_worker_health()

huey/utils.py

@@ -156,3 +156,9 @@ def __enter__(self):
 
     def __exit__(self, exc_type, exc_val, exc_tb):
         self.release()
+
+
+if sys.version_info[0] < 3:
+    time_clock = time.time
+else:
+    time_clock = time.monotonic