登录
首页 >  文章 >  python教程

Python 线程重复执行问题:为什么同一个变量导致多个线程执行结果相同?

时间:2024-11-11 09:40:02 359浏览 收藏

本篇文章向大家介绍《Python 线程重复执行问题:为什么同一个变量导致多个线程执行结果相同?》,主要包括,具有一定的参考价值,需要的朋友可以参考一下。

Python 线程重复执行问题:为什么同一个变量导致多个线程执行结果相同?

python线程重复执行

在以下代码中,预期不同的线程将依次执行,但实际却重复执行了最后一个线程:

import threading, time

num = 5
lock = threading.lock()  # 创建同步锁
l = []

def sub():
    global num
    print('sub %s' % t.name)
    lock.acquire()  # 获得同步锁:不让别的线程在同一时刻运行
    print(t.name)
    temp = num
    time.sleep(1)
    num = temp - 1
    lock.release()  # 解除同步锁
    print('%s ' % t.name, num)

for i in range(5):
    t = threading.thread(target=sub)
    t.start()
    print('start %s' % t.name)
    l.append(t)

for t in l:
    t.join()

print('s', num)

问题根源在于 t 变量全局引用的问题:

  • for 循环中,每次迭代都会创建并启动新线程。
  • 每个线程在进入 sub 函数时都会获取对 t 的引用。
  • 由于 t 是全局变量,循环的最后一次迭代后,t 将指向最后一个创建的线程(也就是线程 5)。

因此,当不同的线程调用 sub 函数时,它们实际都引用的是同一个 t 对象,导致最后仅打印出了线程 5 的输出。

解决方案

要解决此问题,我们需要为每个线程显式传递 t 参数或使用 threading.current_thread() 函数来获取当前线程信息。

修改后的代码:

import threading, time

num = 5
lock = threading.Lock()  # 创建同步锁
# L = []

def sub(t):
    global num
    print('sub %s' % t.name)
    lock.acquire()  # 获得同步锁:不让别的线程在同一时刻运行
    print(threading.current_thread().getName())
    temp = num
    time.sleep(1)
    num = temp - 1
    lock.release()  # 解除同步锁
    print('%s ' % t.name, num)

for i in range(5):
    t = threading.Thread(target=sub)
    t.start()
    print('start %s' % t.name)
    # L.append(t)

# for T in L:
#     T.join()

print('s', num)

以上就是本文的全部内容了,是否有顺利帮助你解决问题?若是能给你带来学习上的帮助,请大家多多支持golang学习网!更多关于文章的相关知识,也可关注golang学习网公众号。

相关阅读
更多>
最新阅读
更多>
课程推荐
更多>