og-worker.py

import queue
from threading import Thread


class Worker(Thread):

    def __init__(self, q, other_arg, *args, **kwargs):
        self.q = q
        self.other_arg = other_arg
        super().__init__(*args, **kwargs)

    def run(self):
        while True:
            try:
                work = self.q.get(timeout=3)  # 3s timeout
                print(f"work: {work}")
            except queue.Empty:
                print("The queue is empty")
                return
            # do whatever work you have to do on work
            print(f"other_arg: {self.other_arg}")
            self.q.task_done()


q = queue.Queue()
for ptf in range(20):
    q.put_nowait(ptf)

for i in range(20):
    Worker(q, i).start()

# blocks until the queue is empty.
q.join()