diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-05-16 15:33:18 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-05-16 15:33:18 +0000 |
| commit | 6dca823a48e1588a991cf3f48990839d7de80085 (patch) | |
| tree | 66e855dbfd70df3a8abac7c64b3de1e2900664f1 /openstack | |
| parent | a13c3d2d2dd14a9ab7fea5f17fdb4ee72323d17a (diff) | |
| parent | d5e57e9ccf47ec7c6365efa36b509c260774bbc8 (diff) | |
| download | oslo-6dca823a48e1588a991cf3f48990839d7de80085.tar.gz oslo-6dca823a48e1588a991cf3f48990839d7de80085.tar.xz oslo-6dca823a48e1588a991cf3f48990839d7de80085.zip | |
Merge "Add DynamicLoopCall timers to ThreadGroups"
Diffstat (limited to 'openstack')
| -rw-r--r-- | openstack/common/threadgroup.py | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/openstack/common/threadgroup.py b/openstack/common/threadgroup.py index 3558b73..6cafbaf 100644 --- a/openstack/common/threadgroup.py +++ b/openstack/common/threadgroup.py @@ -61,6 +61,13 @@ class ThreadGroup(object): self.threads = [] self.timers = [] + def add_dynamic_timer(self, callback, initial_delay=None, + periodic_interval_max=None, *args, **kwargs): + timer = loopingcall.DynamicLoopingCall(callback, *args, **kwargs) + timer.start(initial_delay=initial_delay, + periodic_interval_max=periodic_interval_max) + self.timers.append(timer) + def add_timer(self, interval, callback, initial_delay=None, *args, **kwargs): pulse = loopingcall.FixedIntervalLoopingCall(callback, *args, **kwargs) |