Python多进程示例

教程

在我们之前的教程中，我们学习了Python CSV示例。在这个教程中，我们将学习Python多进程的示例。

Python多进程Process类是一个抽象，它设置了另一个Python进程，提供了运行代码的方法以及父应用程序控制执行的方式。Process类有两个重要的函数 – start()和join()函数。首先，我们需要编写一个将由进程运行的函数。然后，我们需要实例化一个进程对象。如果我们创建了一个进程对象，在我们告诉它通过start()函数开始处理之前，什么都不会发生。然后，进程将运行并返回其结果。之后，我们通过join()函数告诉进程完成。如果没有调用join()函数，进程将保持空闲状态并且不会终止。因此，如果您创建了许多进程而没有终止它们，您可能会面临资源稀缺的问题。然后，您可能需要手动终止它们。一个重要的事情是，如果您想通过进程传递任何参数，您需要使用args关键字参数。以下代码将有助于理解Process类的用法。

from multiprocessing import Process


def print_func(continent='Asia'):
    print('The name of continent is : ', continent)

if __name__ == "__main__":  # confirms that the code is under main function
    names = ['America', 'Europe', 'Africa']
    procs = []
    proc = Process(target=print_func)  # instantiating without any argument
    procs.append(proc)
    proc.start()

    # 使用参数实例化进程
    for name in names:
        # print(name)
        proc = Process(target=print_func, args=(name,))
        procs.append(proc)
        proc.start()

    # 完成进程
    for proc in procs:
        proc.join()

以下代码的输出将是：

Python multiprocessing Queue class

Python的多进程模块提供了`Queue`类，它恰好是一个先进先出的数据结构。它们可以存储任何pickle Python对象（尽管简单的对象最好），非常适用于在进程之间共享数据。当作为参数传递给进程的目标函数时，队列特别有用，以便进程消耗数据。通过使用`put()`函数，我们可以将数据插入队列，使用`get()`我们可以从队列中获取项目。请看下面的代码作为一个快速示例。

from multiprocessing import Queue

colors = ['red', 'green', 'blue', 'black']
cnt = 1
# 实例化一个队列对象
queue = Queue()
print('pushing items to queue:')
for color in colors:
    print('item no: ', cnt, ' ', color)
    queue.put(color)
    cnt += 1

print('\npopping items from queue:')
cnt = 0
while not queue.empty():
    print('item no: ', cnt, ' ', queue.get())
    cnt += 1

Python多进程锁类

Lock类的任务非常简单。它允许代码声明锁定，以便没有其他进程可以执行相似的代码，直到锁定被释放为止。因此，Lock类的任务主要是两个。一个是声明锁，另一个是释放锁。要声明锁，使用`acquire()`函数，要释放锁，使用`release()`函数。