并发篇-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() 实际上意味着等到队列为空,再执行别的操作。

原文发布于微信公众号 - 数据云团(SmartData)

原文发表时间:2018-12-22

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

扫码关注云+社区

领取腾讯云代金券