From a0288763d9d9a985fa127e61d7bbdd660963b965 Mon Sep 17 00:00:00 2001 From: Clint Armstrong Date: Wed, 9 Sep 2015 16:40:33 -0400 Subject: [PATCH] use native thread id --- poller-service.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/poller-service.py b/poller-service.py index 18effffe2..f724dffe4 100755 --- a/poller-service.py +++ b/poller-service.py @@ -233,9 +233,10 @@ next_update = datetime.now() + timedelta(minutes=1) devices_scanned = 0 -def poll_worker(thread_id): +def poll_worker(): global dev_query global devices_scanned + thread_id = threading.current_thread().ident db = DB() while True: dev_row = db.query(dev_query) @@ -289,11 +290,10 @@ def poll_worker(thread_id): releaseLock('{0}.{1}'.format(action, device_id), db) -t = [] for i in range(0, amount_of_workers): - t.append(threading.Thread(target=poll_worker, args=[i])) - t[i].daemon = True - t[i].start() + t = threading.Thread(target=poll_worker) + t.daemon = True + t.start() while True: