本篇内容介绍了“python线程间通信之队列怎么创建”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
为什么需要线程间通信
一个人的力量是有限的,但是团队合作可以发挥更大的作用。而团队协作需要交流和通信来有效的分配任务和协调工作,来保证保时保量的完成工作。
为什么线程间需要通信呢?这就好比一个团队需要完成一个工作,但是这个工作周期性比较长,复杂度也比较高,此时就需要团队协作了,领导就把工作分为了
n份,
a、
b、
c员工每次领取1份工作,做完了再向老板同步,并且领取新的工作,这样的话,工作很快就做完了嘛。
将线程代入上面的例子,在某些任务中,可能需要多个线程来完成同样的任务,所以线程间通信是为了线程之间的协作和同步,更快的完成任务。
线程间通信方式有哪些
在
python多线程编程中,线程间通信方法主要有以下几种:
共享变量
这是最常用,也是用的最多的方式,这个很好理解,在同一进程中,多个线程有一部分内存是共用进程的,所以多个线程可以使用“共享变量”的方式共享同一份数据,通过对该变量的读写操作来实现线程间通信。
队列
在
python中,为我们提供了队列的标准库
Queue,它是标准库中的一个安全队列的实现。作用是可以在多个线程间共享数据,主要用法为通过
get方法将数据放入队列,
get方法将数据从队列中取出来,
管道
python管道是通过
multiprocessing库中的
Pipe实现的,可以在2个线程之间任意传递数据,而且是双向通信的,主要用法为通过
send方法发送数据,通过
recv方法接收数据。
除此之外,还有其他方法,例如 借助第三方工具,比如
redis等。
线程间通信案例之队列
共享变量,我们之前就已经用过了,比如上一节,我们自己实现了
python的读写锁,就用到了共享变量的方式。这里就不再过多阐述了。这里将介绍一下管道的案例:
队列多用于生产者消费者,在
python中,是使用
queue模块下的
Queue方法,创建一个新的队列语句为:
queues = queue.Queue()
其中,
Queue可以传入一个
maxsize,它将作为队列的最大值,默认的话,是无限制。
想要往队列中写入数据的话,使用
put方法即可,例如,向队列写入字符串"123",我们仅需要调用
put方法即可,例如:
queues.put("123")
而想要从队列中获取数据的话,需要使用
get方法,例如:
data = queues.get() print(data)
除此之外,还有队列其他常用的方法,如:
qsize()会返回队列中元素的数量,
empty()会判断队列是否为空,
full()会判断队列是否已经满了。
这里举一个文件分发下载的例子,我们需要定义一个生产者,用于发布任务,定义多个消费者,用于执行任务,代码如下:
在上述代码中,我们定义了生产者和消费者2个类,其初始方法
__init__会传入队列信息,生产者有定义了2个方法,一个是
put,是将元素放入队列中,还有一个是
qsize,是返回当前队列的个数。而消费者只定义了一个方法
get,上面写了一个死循环,向队列获取数据,每获取到一个数据,休息15秒。
在主函数中,我们定义了一个公共的队列
queues,而后定义了生产者
p和消费者
q,二者都传入了同一个队列
queues。最后我们写了3个线程,用于执行消费者
q的
get方法。 和 调用一个生产者方法
put。
执行结果为:
上述结果展现的是,生产者生成数据,而消费者接收。
file_0到
file_9都只被消费了一次,可见队列是自己保证了线程竞争问题的。