def __init__(self, group, task_executor, retry_seconds, **kwargs):
    self._group = group
    self._should_exit = False
    self._next_wakeup = INF
    self._event = threading.Event()
    self._wakeup_lock = threading.Lock()
    self.task_executor = task_executor
    self.default_retry_seconds = retry_seconds

    self._get_time = kwargs.pop('_get_time', time.time)
    if kwargs:
      raise TypeError('Unknown parameters: %s' % ', '.join(kwargs))
Synchronization decorator.
dataset/ETHPy150Open AppScale/appscale/AppServer/google/appengine/api/taskqueue/taskqueue_stub.py/_BackgroundTaskScheduler.__init__--crossover with--dataset/ETHPy150Open blampe/IbPy/ib/lib/__init__.py/synchronized