oci/zeronet
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Noparallel multi thread compatibility

Browse source
This commit is contained in:
shortcutme 2019-12-17 14:51:57 +01:00
parent dfd55c3957
commit 5c1b34387c
No known key found for this signature in database
GPG key ID: 5B63BAE6CB9613AE
1 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/util/Noparallel.py
View file

@ -2,19 +2,24 @@ import gevent
import time import time
from gevent.event import AsyncResult from gevent.event import AsyncResult
from . import ThreadPool
class Noparallel(object): # Only allow function running once in same time
class Noparallel: # Only allow function running once in same time
def __init__(self, blocking=True, ignore_args=False, ignore_class=False, queue=False): def __init__(self, blocking=True, ignore_args=False, ignore_class=False, queue=False):
self.threads = {} self.threads = {}
self.blocking = blocking # Blocking: Acts like normal function else thread returned self.blocking = blocking # Blocking: Acts like normal function else thread returned
self.queue = queue self.queue = queue # Execute again when blocking is done
self.queued = False self.queued = False
self.ignore_args = ignore_args self.ignore_args = ignore_args # Block does not depend on function call arguments
self.ignore_class = ignore_class self.ignore_class = ignore_class # Block does not depeds on class instance
def __call__(self, func): def __call__(self, func):
def wrapper(*args, **kwargs): def wrapper(*args, **kwargs):
if not ThreadPool.isMainThread():
return ThreadPool.main_loop.call(wrapper, *args, **kwargs)
if self.ignore_class: if self.ignore_class:
key = func # Unique key only by function and class object key = func # Unique key only by function and class object
elif self.ignore_args: elif self.ignore_args: