多线程利器－－－队列(queue)

Posted 2021-06-07 管控念头

import threading
import time
import queue # 线程队列
\'\'\'多线程不使用任何锁的情况下，对同一个列表进行删除操作(列表是不安全的数据结构)\'\'\'
# l = [1, 2, 3, 4, 5, 6]
# def num():
#  while l:
#     a = l[-1]
#     print(a)
#     time.sleep(0.5)
#     try:
#        l.remove(a)
#     except Exception as e:
#        print(e)
# if __name__ == \'__main__\':
#  t1 = threading.Thread(target=num)
#  t2 = threading.Thread(target=num)
#  t1.start()
#  t2.start()
#  t1.join()
#  t2.join()
#  print(\'ending...\')
# 最后一个元素两个线程都取到了，进行删除操作时有一个线程先执行，而后执行的线程由于列表最后一个元素已经被前一个线程删除了，所以报错list.remove(x): x not in list


\'\'\'线程队列\'\'\'
q = queue.Queue(3) # Queue()是先进先出，maxsize参数代表只能put3个数据(默认参数maxsize=0，代表无限)，当超过3个数据时，程序卡在了最后一个put且不往下执行，其它线程可以进行get从而才可以继续往下执行
q.put(1)
q.put(\'alex\')
q.put({\'name: mike\'})
# q.put(1, block=False) # 如果block==False(默认为True)，那么put超过指定数量(maxsize)时，会自动报错：queue.Full；另一种写法q.put_nowait(item)
print(q.qsize()) # qsize()是按照队列有多少数据来进行统计，并不是根据maxsize
print(q.empty()) # empty()判断队列是否为空，是则返回True，反之False
print(q.full()) # full()判断队列是否填充满，是则返回True，反之False
# q.task_done()在完成一项工作之后，q.task_done()函数向任务已经完成的队列发送一个信号
# q.join()实际上意味着等到队列为空，再执行别的操作

while True:
   data = q.get(block=False)
   # 当get完最后一个数据时，程序仍未结束，可以理解为当队列还有数据put时还能继续get；如果block==False(默认为True)，没有数据get时报错：_queue.Empty；另一种写法q.get_nowait()
   print(data)
   print(\'------\')


# q = queue.LifoQueue() # LifoQueue()是后进先出(先进后出)
# q.put(1)
# q.put(\'alex\')
# q.put({\'name: mike\'})
#
# while True:
#  data = q.get()
#  print(data)
#  print(\'------\')

# q = queue.PriorityQueue() # Priority优先，按优先级，数字越小优先级越高(第一个索引就是代表优先级)，如果优先级重复会报错：TypeError: \'<\' not supported between instances of \'set\' and \'str\'
# q.put([1, 2])
# q.put([3, \'alex\'])
# q.put([2, {\'name: mike\'}])
#
# while True:
#  data = q.get()
#  print(data[1])
#  print(\'------\')