python 进程池

Python 的进程池是一种用于并发处理任务的机制。它可以在同一时间内处理多个进程，提高程序的执行效率。Python 的 multiprocessing 模块提供了进程池的实现，使用起来非常方便。

以下是一个简单的 Python 进程池的例子：

import multiprocessing

def worker(num):
    """进程池中的工作进程"""
    print("Worker %d is running" % num)

if __name__ == '__main__':
    # 创建进程池，最多同时运行 3 个进程
    pool = multiprocessing.Pool(processes=3)
    
    # 向进程池中添加任务
    for i in range(5):
        pool.apply_async(worker, args=(i,))
    
    # 关闭进程池
    pool.close()
    
    # 等待进程池中的任务执行完毕
    pool.join()

在这个例子中，我们首先定义了一个 worker 函数用于执行进程池中的任务。然后使用 multiprocessing.Pool 创建了一个最多同时运行 3 个进程的进程池。接着使用 pool.apply_async 方法向进程池中添加了 5 个任务。最后，我们调用 pool.close() 关闭进程池，然后调用 pool.join() 等待所有任务执行完毕。

相关问题

Python进程池创建进程

Python中可以使用multiprocessing模块来创建进程池。进程池是一种预先创建一定数量的进程，当有任务需要处理时，就从进程池中取出一个进程来处理任务，处理完毕后再将进程放回进程池中，以便下次使用。以下是一个简单的Python进程池创建进程的例子：

import multiprocessing

def worker(num):
    """进程池中的工作进程"""
    print('Worker %d is running' % num)

if __name__ == '__main__':
    # 创建进程池，池中有3个进程
    pool = multiprocessing.Pool(processes=3)
    # 向进程池中添加任务
    for i in range(5):
        pool.apply_async(worker, args=(i,))
    # 关闭进程池，不再接受新的任务
    pool.close()
    # 等待所有任务完成
    pool.join()

在上面的例子中，首先创建了一个进程池，池中有3个进程。然后向进程池中添加了5个任务，每个任务都是调用worker函数，并传入一个参数。最后关闭进程池，并等待所有任务完成。

python 进程池加锁

进程池加锁是为了在多进程环境下对共享资源进行保护，避免多个进程同时访问和修改同一个资源而导致冲突。下面是一个示例代码，演示了如何在Python中使用进程池加锁：

from multiprocessing import Pool, Lock

def demo01(pid, lock):
    lock.acquire()
    with open('file.txt', "a+", encoding='utf-8') as f:
        f.write(pid)
    lock.release()

if __name__ == '__main__':
    lock = Lock()
    pool = Pool()
    for i in range(3):
        i = str(i)
        pool.apply_async(demo01, args=(i, lock))
    pool.close()
    pool.join()

在上述代码中，首先创建了一个进程池对象`pool`和一个进程锁对象`lock`。然后，使用`apply_async`方法向进程池中添加任务，每个任务都会调用`demo01`函数，并传入进程ID和进程锁作为参数。在`demo01`函数中，通过调用`lock.acquire()`来获取进程锁，然后执行需要保护的操作，最后调用`lock.release()`释放进程锁。

需要注意的是，进程池中的任务是并行执行的，每个任务都会独立获取和释放进程锁，以保证对共享资源的安全访问。