From d5e57e9ccf47ec7c6365efa36b509c260774bbc8 Mon Sep 17 00:00:00 2001 From: Brian Elliott Date: Thu, 9 May 2013 23:50:21 +0000 Subject: Add DynamicLoopCall timers to ThreadGroups Change-Id: I99a67355a7af054c17d3f6807609dbb11ad40631 --- openstack/common/threadgroup.py | 7 +++++++ 1 file changed, 7 insertions(+) (limited to 'openstack') 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) -- cgit