如何使用python在多线程处理单个函数时交替迭代

import threading

# 创建一个锁对象
lock = threading.Lock()

# 定义一个全局变量，用于控制交替迭代
current_thread = 1

def print_numbers(thread_id):
    global current_thread
    for i in range(10):
        # 获取锁
        lock.acquire()
        try:
            # 检查是否轮到当前线程执行
            if current_thread == thread_id:
                print(f"Thread {thread_id}: {i}")
                # 更新当前线程标识
                current_thread = 3 - thread_id  # 切换到另一个线程
            else:
                # 如果不是当前线程，则释放锁并等待下一次获取
                lock.release()
                continue
        finally:
            # 确保锁最终会被释放
            lock.release()

# 创建两个线程
thread1 = threading.Thread(target=print_numbers, args=(1,))
thread2 = threading.Thread(target=print_numbers, args=(2,))

# 启动线程
thread1.start()
thread2.start()

# 等待线程结束
thread1.join()
thread2.join()