多线程（thread+queue 售票）

一、理解

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

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

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

#!/usr/bin/env python
# -*- coding:utf-8 -*-

import time
from threading import Thread
from queue import Queue

tickets = 100
# 队列中，可以放任意类型的数据,线程安全
tickets_queue = Queue(100)
# 声明退出条件
exitFlag = False


class TicketsThread(Thread):

    def __init__(self, thread_id, sell_tickets_queue):
        super().__init__()
        self.thread_id = thread_id
        self.sell_tickets_queue = sell_tickets_queue

    # 代码在run中执行，run中完善功能
    def run(self):
        super().run()
        global tickets
        global exitFlag
        while True:
            # 线程退出的条件
            if exitFlag:
                break

            # 获取队列中数据
            # Queue特点，取出来，没了
            try:
                tickets = self.sell_tickets_queue.get(block=False)
                print('线程：--------%d--------已卖票：%d' % (self.thread_id, tickets))
                time.sleep(1)
                # 通知队列，任务结束
                self.sell_tickets_queue.task_done()
            except Exception as e:
                pass


if __name__ == '__main__':
    '''
    多个线程，执行同一个任务
    100url，一个线程，可以
    10个线程，执行现在请求，优化
    卖票，多线程
    10个窗口帮助我们卖票
    '''
    for i in range(1, 101):
        # 向队列中放入100张票
        tickets_queue.put(i)

    # 创建10个线程，让10个线程一起执行买票
    for i in range(1, 11):
        # 创建卖票线程，并且启动
        my_thread = TicketsThread(i, tickets_queue)
        # 启动,线程中的run方法，就开始执行
        my_thread.start()

    # join()：判断队列是否为空，如果为空，程序继续向下执行，如果不为空，继续等待。（可以理解为队列锁）
    tickets_queue.join()
    exitFlag = True