Skip to content

Commit

Permalink
Update thread name to contain thread number
Browse files Browse the repository at this point in the history
This way loggers that use the thread name display useful information
  • Loading branch information
digitalresistor committed May 27, 2020
1 parent 51f411a commit bebdaf5
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 5 deletions.
8 changes: 5 additions & 3 deletions src/waitress/task.py
Expand Up @@ -57,8 +57,10 @@ def __init__(self):
self.queue_cv = threading.Condition(self.lock)
self.thread_exit_cv = threading.Condition(self.lock)

def start_new_thread(self, target, args):
t = threading.Thread(target=target, name="waitress", args=args)
def start_new_thread(self, target, thread_no):
t = threading.Thread(
target=target, name="waitress-{}".format(thread_no), args=(thread_no,)
)
t.daemon = True
t.start()

Expand Down Expand Up @@ -96,7 +98,7 @@ def set_thread_count(self, count):
thread_no = thread_no + 1
threads.add(thread_no)
running += 1
self.start_new_thread(self.handler_thread, (thread_no,))
self.start_new_thread(self.handler_thread, thread_no)
self.active_count += 1
thread_no = thread_no + 1
if running > count:
Expand Down
4 changes: 2 additions & 2 deletions tests/test_task.py
Expand Up @@ -34,15 +34,15 @@ def test_set_thread_count_increase(self):
L = []
inst.start_new_thread = lambda *x: L.append(x)
inst.set_thread_count(1)
self.assertEqual(L, [(inst.handler_thread, (0,))])
self.assertEqual(L, [(inst.handler_thread, 0)])

def test_set_thread_count_increase_with_existing(self):
inst = self._makeOne()
L = []
inst.threads = {0}
inst.start_new_thread = lambda *x: L.append(x)
inst.set_thread_count(2)
self.assertEqual(L, [(inst.handler_thread, (1,))])
self.assertEqual(L, [(inst.handler_thread, 1)])

def test_set_thread_count_decrease(self):
inst = self._makeOne()
Expand Down

0 comments on commit bebdaf5

Please sign in to comment.