在Python中，在队列不为空的情况下读取并始终调用task_done的最干净的方法是什么？

import threading
import queue

q = queue.Queue()

def process_queue():
    while not q.empty():
        item = q.get()
        # 处理任务
        # ...
        q.task_done()

num_threads = 5  # 定义线程数量
for i in range(num_threads):
    t = threading.Thread(target=process_queue)
    t.start()

# 添加任务到队列
# ...
q.join()  # 等待队列中的任务全部完成

import multiprocessing
import queue

q = multiprocessing.Queue()

def process_queue():
    while not q.empty():
        item = q.get()
        # 处理任务
        # ...
        q.task_done()

num_processes = 5  # 定义进程数量
for i in range(num_processes):
    p = multiprocessing.Process(target=process_queue)
    p.start()

# 添加任务到队列
# ...
q.join()  # 等待队列中的任务全部完成