当前位置:   article > 正文

Python3 threading

python3 threading

python2中的thread在python3中升级成了threading ,原先的thread变成了_thread ,建议大家使用threading ,Python中虽然有GIL的存在,并不能并行线程,但是对于IO密集型的应用还是挺方便快捷的。
这里需要注意一个点:GIL并不能保证线程安全,看以下例子:
线程安全、非线程安全的相关概念
threading 并发针对同一个变量,需要加锁。
例子1:

import threading

num = 0

def task(count):
    global num
    for _ in range(count):
        num = num+1


if __name__ == '__main__':
    count = 1000000
    threads = []
    for _ in range(7):
        t1 = threading.Thread(target=task, args=(count,))
        t1.start()
        threads.append(t1)

    for t in threads:
        t.join()

    print(num)
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22

当我们使用lock就可以避免这个问题:
例子2:

import threading

num = 0
lock = threading.Lock()


def task(count):
    global num, lock
    lock.acquire()
    for _ in range(count):
        num = num+1
    lock.release()


if __name__ == '__main__':
    count = 1000000
    threads = []
    for _ in range(7):
        t1 = threading.Thread(target=task, args=(count,))
        t1.start()
        threads.append(t1)

    for t in threads:
        t.join()

    print(num)

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/IT小白/article/detail/143439
推荐阅读
相关标签
  

闽ICP备14008679号