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

Save last lock time

Browse source
This commit is contained in:
shortcutme 2019-12-18 16:42:47 +01:00
parent 845b50915d
commit 7af8d1cd93
No known key found for this signature in database
GPG key ID: 5B63BAE6CB9613AE
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/util/ThreadPool.py
View file

@ -72,8 +72,10 @@ class Lock:
self.lock = gevent._threading.Lock() self.lock = gevent._threading.Lock()
self.locked = self.lock.locked self.locked = self.lock.locked
self.release = self.lock.release self.release = self.lock.release
self.time_lock = 0
def acquire(self, *args, **kwargs): def acquire(self, *args, **kwargs):
self.time_lock = time.time()
if self.locked() and isMainThread(): if self.locked() and isMainThread():
# Start in new thread to avoid blocking gevent loop # Start in new thread to avoid blocking gevent loop
return lock_pool.apply(self.lock.acquire, args, kwargs) return lock_pool.apply(self.lock.acquire, args, kwargs)