Hopiu/linkchecker
1
0
Fork 0
mirror of https://github.com/Hopiu/linkchecker.git synced 2026-03-25 18:30:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Support semaphores.

Browse source
This commit is contained in:
Bastian Kleineidam 2012-10-09 19:46:06 +02:00
parent ad8525c483
commit 7d3ece502c
1 changed files with 16 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
linkcheck/lock.py
View file

@ -20,11 +20,13 @@ Locking utility class.
import threading
from . import log, LOG_THREAD
def get_lock (name):
def get_lock (name, debug=False):
"""Return a new thread lock object."""
return threading.Lock()
lock = threading.Lock()
# for thread debugging, use the DebugLock wrapper
#return DebugLock(threading.Lock(), name)
if debug:
lock = DebugLock(lock, name)
return lock
class DebugLock (object):
@ -47,3 +49,14 @@ class DebugLock (object):
threadname = threading.currentThread().getName()
log.debug(LOG_THREAD, "Release %s for %s", self.name, threadname)
self.lock.release()
def get_semaphore(name, value=None, debug=False):
if value is None:
lock = threading.Semaphore()
else:
lock = threading.BoundedSemaphore(value)
if debug:
lock = DebugLock(lock, name)
return lock