[已解决]python线程锁怎么用?

vcbeaut

线程同步的方式有很多，哪种比较常用？

最佳答案

月排行榜 / 总排行榜

suchocolate

2020-9-27 09:24:17

两种方式：全局变量和队列。（以下代码抄自明日科技《python从入门到项目实践》）
1.全局变量+互斥锁：

1. from threading import Thread,Lock
   
2. import time
   
3. n=100 # 共100张票
   
4. 
   
5. def task():
   
6.     global n
   
7.     mutex.acquire()             # 上锁
   
8.     temp=n                      # 赋值给临时变量
   
9.     time.sleep(0.1)             # 休眠0.1秒
   
10.     n=temp-1                    # 数量减1
    
11.     print('购买成功，剩余%d张电影票'%n)
    
12.     mutex.release()             # 释放锁
    
13. 
    
14. if __name__ == '__main__':
    
15.     mutex=Lock()                # 实例化Lock类
    
16.     t_l=[]                      # 初始化一个列表
    
17.     for i in range(10):
    
18.         t=Thread(target=task)   # 实例化线程类
    
19.         t_l.append(t)           # 将线程实例存入列表中
    
20.         t.start()               # 创建线程
    
21.     for t in t_l:
    
22.         t.join()                # 等待子线程结束

复制代码

2.队列：

1. from queue import Queue
   
2. import random,threading,time
   
3. 
   
4. # 生产者类
   
5. class Producer(threading.Thread):
   
6.     def __init__(self, name,queue):
   
7.         threading.Thread.__init__(self, name=name)
   
8.         self.data=queue
   
9.     def run(self):
   
10.         for i in range(5):
    
11.             print("生成者%s将产品%d加入队列!" % (self.getName(), i))
    
12.             self.data.put(i)
    
13.             time.sleep(random.random())
    
14.         print("生成者%s完成!" % self.getName())
    
15. 
    
16. # 消费者类
    
17. class Consumer(threading.Thread):
    
18.     def __init__(self,name,queue):
    
19.         threading.Thread.__init__(self,name=name)
    
20.         self.data=queue
    
21.     def run(self):
    
22.         for i in range(5):
    
23.             val = self.data.get()
    
24.             print("消费者%s将产品%d从队列中取出!" % (self.getName(),val))
    
25.             time.sleep(random.random())
    
26.         print("消费者%s完成!" % self.getName())
    
27. 
    
28. if __name__ == '__main__':
    
29.     print('-----主线程开始-----')
    
30.     queue = Queue()        # 实例化队列
    
31.     producer = Producer('Producer',queue)   # 实例化线程Producer，并传入队列作为参数
    
32.     consumer = Consumer('Consumer',queue)   # 实例化线程Consumer，并传入队列作为参数
    
33.     producer.start()    # 启动线程Producer
    
34.     consumer.start()    # 启动线程Consumer
    
35.     producer.join()     # 等待线程Producer结束
    
36.     consumer.join()     # 等待线程Consumer结束
    
37.     print('-----主线程结束-----')
    
38. 
    

复制代码

跳转到最佳答案楼层

suchocolate

两种方式：全局变量和队列。（以下代码抄自明日科技《python从入门到项目实践》）
1.全局变量+互斥锁：

1. from threading import Thread,Lock
   
2. import time
   
3. n=100 # 共100张票
   
4. 
   
5. def task():
   
6.     global n
   
7.     mutex.acquire()             # 上锁
   
8.     temp=n                      # 赋值给临时变量
   
9.     time.sleep(0.1)             # 休眠0.1秒
   
10.     n=temp-1                    # 数量减1
    
11.     print('购买成功，剩余%d张电影票'%n)
    
12.     mutex.release()             # 释放锁
    
13. 
    
14. if __name__ == '__main__':
    
15.     mutex=Lock()                # 实例化Lock类
    
16.     t_l=[]                      # 初始化一个列表
    
17.     for i in range(10):
    
18.         t=Thread(target=task)   # 实例化线程类
    
19.         t_l.append(t)           # 将线程实例存入列表中
    
20.         t.start()               # 创建线程
    
21.     for t in t_l:
    
22.         t.join()                # 等待子线程结束

复制代码

2.队列：

1. from queue import Queue
   
2. import random,threading,time
   
3. 
   
4. # 生产者类
   
5. class Producer(threading.Thread):
   
6.     def __init__(self, name,queue):
   
7.         threading.Thread.__init__(self, name=name)
   
8.         self.data=queue
   
9.     def run(self):
   
10.         for i in range(5):
    
11.             print("生成者%s将产品%d加入队列!" % (self.getName(), i))
    
12.             self.data.put(i)
    
13.             time.sleep(random.random())
    
14.         print("生成者%s完成!" % self.getName())
    
15. 
    
16. # 消费者类
    
17. class Consumer(threading.Thread):
    
18.     def __init__(self,name,queue):
    
19.         threading.Thread.__init__(self,name=name)
    
20.         self.data=queue
    
21.     def run(self):
    
22.         for i in range(5):
    
23.             val = self.data.get()
    
24.             print("消费者%s将产品%d从队列中取出!" % (self.getName(),val))
    
25.             time.sleep(random.random())
    
26.         print("消费者%s完成!" % self.getName())
    
27. 
    
28. if __name__ == '__main__':
    
29.     print('-----主线程开始-----')
    
30.     queue = Queue()        # 实例化队列
    
31.     producer = Producer('Producer',queue)   # 实例化线程Producer，并传入队列作为参数
    
32.     consumer = Consumer('Consumer',queue)   # 实例化线程Consumer，并传入队列作为参数
    
33.     producer.start()    # 启动线程Producer
    
34.     consumer.start()    # 启动线程Consumer
    
35.     producer.join()     # 等待线程Producer结束
    
36.     consumer.join()     # 等待线程Consumer结束
    
37.     print('-----主线程结束-----')
    
38. 
    

复制代码