python thread 并发且顺序运行示例

当我们在python中使用多线程编程时，为了保证多个线程能够在正确的顺序运行，我们需要进行线程同步操作，避免数据的竞争和混乱。下面我将提供两个示例来展示如何在python中使用线程同步操作实现并发且顺序运行的效果。

1. 通过Lock对象实现线程同步

首先我们需要导入threading模块中的Lock类，这是python内置的线程同步机制之一。在本次示例中，我们将创建两个线程，一个线程输出数字1-5，另一个线程输出数字6-10，并按照1-10的顺序进行打印。

import threading

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

def task1():
    lock.acquire()
    try:
        for i in range(1, 6):
            print(i)
    finally:
        lock.release()

def task2():
    lock.acquire()
    try:
        for i in range(6, 11):
            print(i)
    finally:
        lock.release()

# 创建并启动线程
t1 = threading.Thread(target=task1)
t2 = threading.Thread(target=task2)
t1.start()
t2.start()

在上面的代码示例中，我们使用lock.acquire()方法获取锁，确保同一时间只有一个线程可以执行。当执行完任务后，使用lock.release()方法释放锁，让其他线程可以继续执行。通过这种方式，我们保证了程序的并发且顺序运行。

2. 通过Condition对象实现线程同步

除了使用Lock对象外，我们还可以使用Condition对象来进行线程同步。Condition对象比Lock对象更加灵活，可以让我们更加方便地控制线程的执行顺序。下面的代码示例中，我们将创建两个线程，一个线程输出字母A-E，另一个线程输出字母F-J，并按照A-J的顺序进行打印。

import threading

# 创建一个共享的Condition对象
condition = threading.Condition()

def task1():
    with condition:
        for i in range(65, 70):
            print(chr(i))
            condition.notify()  # 唤醒等待的线程
            condition.wait()    # 让当前线程等待

def task2():
    with condition:
        for i in range(70, 75):
            condition.wait()    # 让当前线程等待
            print(chr(i))
            condition.notify()  # 唤醒等待的线程

# 创建并启动线程
t1 = threading.Thread(target=task1)
t2 = threading.Thread(target=task2)
t1.start()
t2.start()

在上述代码示例中，我们使用with condition作为代码上下文管理器，确保在需要时可以自动获取并释放Condition对象。当我们执行的条件不满足时，使用condition.wait()方法来让线程等待。在条件满足时，使用condition.notify()方法来唤醒等待的线程，让线程继续执行。通过Condition对象，我们可以更加灵活地控制线程的执行顺序，从而实现并发且顺序运行的效果。

阅读剩余 32%