简单谈谈python中的Queue与多进程

Python中的Queue模块是实现多线程编程中重要的一个模块，它可以用来实现多线程之间的通信和数据传递。同时，Python中也提供了多进程的支持，与多线程一样，多进程编程中也需要用到队列。

Queue模块

Queue是Python中提供的一个标准库，可以用于实现多线程之间的通信。Queue模块提供的队列分为三种，分别是FIFO队列、LIFO队列和优先级队列。

FIFO队列

FIFO队列是最常用的队列类型，它是按照先进先出的原则进行数据处理。Queue模块提供了FIFOQueue类，可以用来创建一个FIFO队列。示例代码如下：

import queue

q = queue.Queue()
for i in range(5):
    q.put(i)
while not q.empty():
    print(q.get())

LIFO队列

LIFO队列是按照后进先出的原则进行数据处理。Queue模块提供了LifoQueue类，可以用来创建一个LIFO队列。示例代码如下：

import queue

q = queue.LifoQueue()
for i in range(5):
    q.put(i)
while not q.empty():
    print(q.get())

优先级队列

优先级队列是按照数据优先级进行处理的队列。Queue模块提供了PriorityQueue类，可以用来创建一个优先级队列。示例代码如下：

import queue

q = queue.PriorityQueue()
q.put((1, 'data1'))
q.put((2, 'data2'))
q.put((3, 'data3'))
while not q.empty():
    print(q.get()[1])

多进程

在Python中，可以使用multiprocessing模块来支持多进程编程。通过创建多个进程来完成多任务处理，可以极大地提高程序的运行效率。

创建进程

multiprocessing模块提供了Process类，可以用来创建进程。示例代码如下：

from multiprocessing import Process
import time

def func(name):
    print(name)
    time.sleep(3)

if __name__ == '__main__':
    p = Process(target=func, args=('child process',))
    p.start()
    p.join()

进程间通信

进程间通信在多进程编程中比较重要，可以通过Queue模块来完成。Queue模块中的队列可以在多个进程中进行共享。示例代码如下：

from multiprocessing import Process, Queue

def func(q):
    q.put('child process')

if __name__ == '__main__':
    q = Queue()
    p = Process(target=func, args=(q,))
    p.start()
    print(q.get())
    p.join()

在上面的示例代码中，我们通过Queue来实现进程间通信。在父进程中创建了一个队列，并将其作为参数传递给子进程。在子进程中，我们将数据'child process'放到队列中，然后在父进程中取出队列中的数据，就完成了进程间数据传递的操作。

以上是Python中Queue与多进程的一些基本使用方法，希望可以对你有所帮助。