并发篇-python并发通信-2

互斥锁是指锁住一个线程或进程执行，执行完后再执行下一个。

死锁是指两个或两个以上的进程或线程在执行过程中，因争夺资源而造成的一种互相等待的现象，若无外力作用，它们都将无法推进下去。

>>>简单实现一个多线程：

# 查看线程

>>> threading.enumerate()

>>>共享全局变量多线程，

在同一进程下的多个线程里全局变量是共享的：

线程与进程安全的队列

Python的Queue模块中提供了同步的、线程安全的队列类，包括FIFO（先入先出)QueueLIFO（后入先出）队列LifoQueue，和优先级队列PriorityQueue。

这些队列都实现了锁原语，能够在多线程中直接使用。可以使用队列来实现线程间的同步。

>>>python多线程--优先级队列（Queue）

# 创建新线程

# 填充队列

#执行结果

队列算公共资源嘛？

如果只是一个线程/进程在使用，那么它并不算公共资源。

但是一旦多个线程/进程在同时使用，那么它就是一个公共资源

是否需要对其加锁？

如果被当作公共资源使用，那么按理说是必须要加锁的。

但是，线程安全或进程安全的队列中已经帮我们实现了锁。

因此我们不需要再自己使用锁来同步。

Queue模块中的常用方法:

• .qsize() 返回队列的大小
• .empty() 如果队列为空，返回True,反之False
• .full() 如果队列满了，返回True,反之False
• .full 与 maxsize 大小对应
• .get([block[, timeout]])获取队列，timeout等待时间
• .get_nowait() 相当Queue.get(False)
• .put(item) 写入队列，timeout等待时间
• .put_nowait(item) 相当Queue.put(item, False)
• .task_done() 在完成一项工作之后，Queue.task_done()函数向任务已经完成的队列发送一个信号
• .join() 实际上意味着等到队列为空，再执行别的操作。