mirror of
https://github.com/Pardus-LiderAhenk/ahenk
synced 2024-11-25 20:32:20 +03:00
timer method added for using with some specific function which need timeout actions
This commit is contained in:
parent
93cedac5ef
commit
d63a455d39
2 changed files with 60 additions and 0 deletions
8
opt/ahenk/base/timer/setup_timer.py
Normal file
8
opt/ahenk/base/timer/setup_timer.py
Normal file
|
@ -0,0 +1,8 @@
|
||||||
|
from multiprocessing import Process
|
||||||
|
|
||||||
|
|
||||||
|
class SetupTimer:
|
||||||
|
@staticmethod
|
||||||
|
def start(timer):
|
||||||
|
thread_timer = Process(target=timer.run)
|
||||||
|
thread_timer.start()
|
52
opt/ahenk/base/timer/timer.py
Normal file
52
opt/ahenk/base/timer/timer.py
Normal file
|
@ -0,0 +1,52 @@
|
||||||
|
import time
|
||||||
|
|
||||||
|
|
||||||
|
class Timer:
|
||||||
|
def __init__(self, timeout, timeout_function, checker_func=None, checker_success_function=None, **kwargs):
|
||||||
|
self.timeout = int(timeout)
|
||||||
|
self.timeout_function = timeout_function
|
||||||
|
self.timeout_function_args = None
|
||||||
|
self.checker_func_args = None
|
||||||
|
self.checker_success_function_args = None
|
||||||
|
|
||||||
|
if kwargs is not None and kwargs['kwargs'] is not None:
|
||||||
|
if 'timeout_args' in kwargs['kwargs']:
|
||||||
|
self.timeout_function_args = kwargs['kwargs']['timeout_args']
|
||||||
|
|
||||||
|
if 'checker_args' in kwargs['kwargs']:
|
||||||
|
self.checker_func_args = kwargs['kwargs']['checker_args']
|
||||||
|
|
||||||
|
if 'success_args' in kwargs['kwargs']:
|
||||||
|
self.checker_success_function_args = kwargs['kwargs']['success_args']
|
||||||
|
|
||||||
|
self.checker_func = checker_func
|
||||||
|
self.checker_success_function = checker_success_function
|
||||||
|
|
||||||
|
def run_function(self, function, parameter=None):
|
||||||
|
if function is not None:
|
||||||
|
if parameter is None:
|
||||||
|
function()
|
||||||
|
else:
|
||||||
|
function(parameter)
|
||||||
|
|
||||||
|
def run(self):
|
||||||
|
timer = self.timeout
|
||||||
|
|
||||||
|
while timer > 0:
|
||||||
|
|
||||||
|
if self.checker_func is not None:
|
||||||
|
if self.checker_func_args is not None:
|
||||||
|
if self.checker_func(self.checker_func_args) is True:
|
||||||
|
self.run_function(self.checker_success_function, self.checker_success_function_args)
|
||||||
|
return
|
||||||
|
else:
|
||||||
|
if self.checker_func() is True:
|
||||||
|
self.run_function(self.checker_success_function, self.checker_success_function_args)
|
||||||
|
return
|
||||||
|
|
||||||
|
time.sleep(1)
|
||||||
|
timer -= 1
|
||||||
|
if self.timeout_function_args is not None:
|
||||||
|
self.timeout_function(self.timeout_function_args)
|
||||||
|
else:
|
||||||
|
self.timeout_function()
|
Loading…
Reference in a new issue