Python笔记：线程的互斥锁

曾经终败给现在 2022-01-23 12:34 250阅读 0赞

### 文章目录 ###

*  简介
 *  例子一
 *  例子二

# 简介 #

我们知道进程之间不能直接共享信息，但一个进程内的所有线程可以共享全局变量，进程内的全局变量能够在不使用其他方式的前提下完成多线程之间的数据共享，由于线程可以对全局变量随意修改，这就可能造成多线程之间对全局变量的混乱操作。“互斥锁”(Mutual exclusion ,缩写 Mutex)的作用就是防止多个线程同时读写某一块内存区域。互斥锁为资源引入一个状态：锁定和非锁定。某个线程要更改共享数据时，先要将其锁定，此时资源的状态为"锁定"，其他线程不可访问，直到该线程释放资源，将资源的状态变为"非锁定"时，其他的线程才能再次锁定该资源，才能访问该内存区域。互斥锁保证了每次只有一个线程进行写入操作，保证多线程情况下数据的正确性。

# 例子一 #

import threading 
    import time
    n=100
    def task():
        global n
        mutex.acquire()#上锁
        temp=n#赋值给临时变量
        time.sleep(0.1)#休眠0.1秒
        n=temp-1#数量减1
        cur=threading.currentThread()
        print(cur.getName(),"购买成功，剩余%d张电影票"%n)
        mutex.release()#释放锁
    if __name__=="__main__":
        mutex=threading.Lock()
        threads=[]#将所有的线程对象放入一个列表中
        for i in range(10):
            t=threading.Thread(target=task,name="线程-%s"%str(i+1))
            threads.append(t)
            t.start()
        for t in threads:
            t.join()#此处的join函数子线程按顺序执行，即i线程跑完后才能继续跑下一个线程

输出

线程-1 购买成功，剩余99张电影票
    线程-2 购买成功，剩余98张电影票
    线程-3 购买成功，剩余97张电影票
    线程-4 购买成功，剩余96张电影票
    线程-5 购买成功，剩余95张电影票
    线程-6 购买成功，剩余94张电影票
    线程-7 购买成功，剩余93张电影票
    线程-8 购买成功，剩余92张电影票
    线程-9 购买成功，剩余91张电影票
    线程-10 购买成功，剩余90张电影票

# 例子二 #

"""" 实现线程同步 """
    import threading
    import time
    class myThread(threading.Thread):
        def __init__(self,threadID,name,delay):
            threading.Thread.__init__(self)
            self.threadID=threadID
            self.name=name
            self.delay=delay
        def run(self):
            print("开启线程："+self.name)
            #获取锁，用于线程同步
            threadLock.acquire()
            print_time(self.name,self.delay,3)#将函数print_time锁定后,只有当前线程才可调用
            #释放锁，开启下一个线程
            threadLock.release()
    def print_time(threadName,delay,counter):
        while counter:
            time.sleep(delay)
            print("%s:%s" % (threadName,time.ctime(time.time())))
            counter-=1
    threadLock=threading.Lock()
    threads=[]
    if __name__=="__main__":
        #创建线程
        thread1 = myThread(1,"Thread-1",1)
        thread2 = myThread(2, "Thread-2", 2)
        #开启新线程
        thread1.start()
        thread2.start()
        #添加线程到线程列表
        threads.append(thread1)
        threads.append(thread2)
        #等待所有线程完成
        for t in threads:
            t.join()
        print("退出主线程")

输出:

开启线程：Thread-1
    开启线程：Thread-2
    Thread-1:Mon Jun  3 20:45:28 2019
    Thread-1:Mon Jun  3 20:45:29 2019
    Thread-1:Mon Jun  3 20:45:30 2019
    Thread-2:Mon Jun  3 20:45:32 2019
    Thread-2:Mon Jun  3 20:45:34 2019
    Thread-2:Mon Jun  3 20:45:37 2019
    退出主线程