work on example

tests/thread.py

@@ -4,53 +4,48 @@ import queue
 import threading
 import time
 
-
-exitFlag = 0
+exitFlag = False
 
 
 class myThread (threading.Thread):
-    def __init__(self, threadID, name, q):
+    def __init__(self, id, q):
         threading.Thread.__init__(self)
-        self.threadID = threadID
-        self.name = name
+        self.id = id
         self.q = q
 
     def run(self):
-        print("Starting " + self.name)
-        process_data(self.name, self.q)
-        print("Exiting " + self.name)
+        print(f"Thread-{self.id} Starting ")
+        process_data(self.id, self.q)
+        print(f"Thread-{self.id} Done.")
 
 
-def process_data(threadName, q):
+def process_data(id, q):
     while not exitFlag:
         queueLock.acquire()
         if not workQueue.empty():
             data = q.get()
             queueLock.release()
-            print("%s processing %s" % (threadName, data))
+            print(f"Thread-{id} processing {data}")
         else:
             queueLock.release()
         time.sleep(1)
 
 
-threadList = ["Thread-1", "Thread-2"]
-nameList = ["One", "Two", "Three", "Four", "Five", "Six", 'Seven']
+maxThread = 2
+workList = ["One", "Two", "Three", "Four", "Five", "Six", 'Seven']
 queueLock = threading.Lock()
-workQueue = queue.Queue(10)
+workQueue = queue.Queue()
 threads = []
-threadID = 1
-
 
 # Create new threads
-for tName in threadList:
-    thread = myThread(threadID, tName, workQueue)
+for i in range(maxThread):
+    thread = myThread(i, workQueue)
     thread.start()
     threads.append(thread)
-    threadID += 1
 
 # Fill the queue
 queueLock.acquire()
-for word in nameList:
+for word in workList:
     workQueue.put(word)
 queueLock.release()
 
@@ -59,9 +54,10 @@ while not workQueue.empty():
     pass
 
 # Notify threads it's time to exit
-exitFlag = 1
+exitFlag = True
 
 # Wait for all threads to complete
 for t in threads:
     t.join()
+
 print("Exiting Main Thread")