added onionrthreads to replace communicator timers

这个提交包含在:
Kevin 2020-07-29 20:36:41 -05:00
父节点 6f1daf50d3
当前提交 0b34aa7385
共有 1 个文件被更改,包括 25 次插入0 次删除

查看文件

@ -0,0 +1,25 @@
from typing import Callable
from typing import Iterable
from threading import Thread
from utils.bettersleep import better_sleep
def _onionr_thread(func: Callable, args: Iterable,
sleep: int, initial_sleep):
better_sleep(initial_sleep)
while True:
func(*args)
better_sleep(sleep)
def add_onionr_thread(
func: Callable, args: Iterable,
sleep: int, initial_sleep: int = 5):
"""Spawn a new onionr thread that exits when the main thread does.
Runs in an infinite loop with sleep between calls
Passes in an interable args and sleep variables"""
Thread(target=_onionr_thread,
args=(func, args, sleep, initial_sleep), daemon=True).start()