Python连载33-共享变量加锁、释放

时间：2019-08-28 01:34:20 阅读：131 评论：0 收藏：0 [点我收藏+]

一、共享变量

共享变量：当多个线程访问同一个变量的时候。会产生共享变量的问题。

例子：

import threading

sum = 0

loopSum = 1000000

def myAdd():

    global sum, loopSum

    for i in range(1,loopSum):

        sum += 1

def myMinu():

    global sum, loopSum

    for i in range(1,loopSum):

        sum -= 1

if __name__ == "__main__":

    print("Dont,,,,,,,{0}".format(sum))

    t1 = threading.Thread(target=myAdd,args=())

    t2 = threading.Thread(target=myMinu,args=())

    t1.start()

    t2.start()

    t1.join()

    t2.join()

    print("Done,,,,,,{0}".format(sum))

技术图片

正如上面的结果可以看出：并不是我们期望的0，而是-286705，这就是因为我们共享变量了，同时对变量进行了操作，程序并不是原子的。

2.解决方案：使用“锁”，“信号灯”

（1）锁lock：是一个标志，表示一个线程在占用一些资源。

使用方式：先上锁，然后使用共享资源，放心的使用，最后再释放锁，即释放了这个变量。

锁哪个：哪个资源需要共享，那么就锁谁

import threading

sum = 0

loopSum = 1000000

lock = threading.Lock()

#先生成一个锁的实例

def myAdd():

    global sum, loopSum

    for i in range(1,loopSum):

        lock.acquire()#这里申请了一把锁

        sum += 1

        lock.release()#注意千万不要忘了释放锁

def myMinu():

    global sum, loopSum

    for i in range(1,loopSum):

        lock.acquire()

        sum -= 1

        lock.release()

if __name__ == "__main__":

    print("Done,,,,,,,{0}".format(sum))

    t1 = threading.Thread(target=myAdd,args=())

    t2 = threading.Thread(target=myMinu,args=())

    t1.start()

    t2.start()

    t1.join()

    t2.join()

    print("Done,,,,,,{0}".format(sum))