多线程（thread+queue 售票）

1、理解

若是线程里每从队列里取一次，但没有执行task_done()，则join没法判断队列到底有没有结束，在最后执行个join()是等不到结果的，会一直挂起。
能够理解为，每task_done一次 就从队列里删掉一个元素，这样在最后join的时候根据队列长度是否为零来判断队列是否结束，从而执行主线程。

Queue.task_done() 在完成一项工做以后，Queue.task_done()函数向任务已经完成的队列发送一个信号

Queue.join() 实际上意味着等到队列为空，再执行别的操做

 1 #!/usr/bin/env python
 2 # -*- coding:utf-8 -*-
 3 
 4 import time
 5 from threading import Thread
 6 from queue import Queue
 7 
 8 tickets = 100
 9 # 队列中，能够听任意类型的数据,线程安全
10 tickets_queue = Queue(100)
11 # 声明退出条件
12 exitFlag = False
13 
14 
15 class TicketsThread(Thread):
16 
17     def __init__(self, thread_id, sell_tickets_queue):
18         super().__init__()
19         self.thread_id = thread_id
20         self.sell_tickets_queue = sell_tickets_queue
21 
22     # 代码在run中执行，run中完善功能
23     def run(self):
24         super().run()
25         global tickets
26         global exitFlag
27         while True:
28             # 线程退出的条件
29             if exitFlag:
30                 break
31 
32             # 获取队列中数据
33             # Queue特色，取出来，没了
34             try:
35                 tickets = self.sell_tickets_queue.get(block=False)
36                 print('线程：--------%d--------已卖票：%d' % (self.thread_id, tickets))
37                 time.sleep(1)
38                 # 通知队列，任务结束
39                 self.sell_tickets_queue.task_done()
40             except Exception as e:
41                 pass
42 
43 
44 if __name__ == '__main__':
45     '''
46     多个线程，执行同一个任务
47     100url，一个线程，能够
48     10个线程，执行如今请求，优化
49     卖票，多线程
50     10个窗口帮助咱们卖票
51     '''
52     for i in range(1, 101):
53         # 向队列中放入100张票
54         tickets_queue.put(i)
55 
56     # 建立10个线程，让10个线程一块儿执行买票
57     for i in range(1, 11):
58         # 建立卖票线程，而且启动
59         my_thread = TicketsThread(i, tickets_queue)
60         # 启动,线程中的run方法，就开始执行
61         my_thread.start()
62 
63     # join()：判断队列是否为空，若是为空，程序继续向下执行，若是不为空，继续等待。（能够理解为队列锁）
64     tickets_queue.join()
65     exitFlag = True

多线程+队列锁=>买票