python threading 冲突的例子

以下是一个简单的 Python 多线程程序，演示了线程冲突的问题：

import threading

x = 0

def increment():
    global x
    x += 1

def thread_task():
    for _ in range(100000):
        increment()

def main_task():
    global x
    x = 0

    t1 = threading.Thread(target=thread_task)
    t2 = threading.Thread(target=thread_task)

    t1.start()
    t2.start()

    t1.join()
    t2.join()

if __name__ == '__main__':
    for i in range(10):
        main_task()
        print("Iteration {0}: x = {1}".format(i, x))

在这个程序中，我们定义了一个全局变量 `x`，并且在两个线程中使用 `increment` 函数来递增它的值。我们启动了 10 次主任务，每次主任务中都会启动两个线程，每个线程都会递增 `x` 的值 100000 次。

理想情况下，我们期望每次主任务结束后，`x` 的值应该是 200000。但是，由于线程冲突的问题，实际上每次主任务结束后，`x` 的值都会小于 200000。这是因为多个线程同时访问同一个全局变量 `x`，从而导致竞争条件和冲突问题。

因此，为了解决这个问题，我们需要使用锁来保护共享资源的访问。