Hopiu/linkchecker
1
0
Fork 0
mirror of https://github.com/Hopiu/linkchecker.git synced 2026-05-04 21:04:41 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

set names of worker and status threads

Browse source 
git-svn-id: https://linkchecker.svn.sourceforge.net/svnroot/linkchecker/trunk/linkchecker@3175 e7d03fd6-7b0d-0410-9947-9c21f3af8025
This commit is contained in:
calvin 2006-05-14 17:50:36 +00:00
parent 523e6e8e43
commit afdccbaa80
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
linkcheck/director/aggregator.py
View file

@ -59,8 +59,10 @@ class Aggregate (object):
self.worker()
def worker (self):
name = threading.currentThread().getName()
while True:
self.check_url()
threading.currentThread().setName(name)
if self.urlqueue.empty():
break
@ -68,6 +70,8 @@ class Aggregate (object):
url_data = self.urlqueue.get()
if url_data is not None:
try:
url = self.config['logger'].encode(url_data.url)
threading.currentThread().setName(url)
if not url_data.has_result:
url_data.check()
self.logger.log_url(url_data)
@ -76,6 +80,7 @@ class Aggregate (object):
def status (self):
start_time = time.time()
threading.currentThread().setName("Status")
while True:
time.sleep(5)
if not status.status_is_active():
@ -85,4 +90,3 @@ class Aggregate (object):
def abort (self):
self.urlqueue.do_shutdown()
self.urlqueue.join(timeout=10)