Python进程间通信常用的几种方式

这篇具有很好参考价值的文章主要介绍了Python进程间通信常用的几种方式。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

Python进程间通信常用的有以下几种方式:

1. 队列(Queue) 多个进程使用队列进行数据交换。进程通过队列发送和接收对象。

队列是一个可以存储任意类型数据的数据结构,而且支持多线程操作,因此在Python的多进程编程中,可以利用队列来实现进程间通信。

下面是一个简单的利用队列实现进程间通信的示例代码:

import multiprocessing

def producer(queue):
    for i in range(10):
        queue.put(i)

def consumer(queue):
    while True:
        item = queue.get()
        if item is None:
            break
        print(item)

if __name__ == '__main__':
    queue = multiprocessing.Queue()

    p1 = multiprocessing.Process(target=producer, args=(queue,))
    p2 = multiprocessing.Process(target=consumer, args=(queue,))

    p1.start()
    p2.start()

    p1.join()
    queue.put(None)
    p2.join()

在这个示例代码中,我们定义了两个函数producer和consumer,分别用于将数据写入队列和从队列中读取数据。我们初始化了一个队列,然后创建了两个进程p1和p2,p1用于执行producer函数,p2用于执行consumer函数。

2. 管道(Pipe) 管道可用于具有亲缘关系的进程间的通信,例如两个进程之间的单向通信。

管道也是一种进程间通信方式,管道分为普通管道(只能在父进程和子进程之间使用)和命名管道(可以在多个进程之间使用)。

下面是一个简单的利用管道实现进程间通信的示例代码:

import multiprocessing

def producer(pipe):
    for i in range(10):
        pipe.send(i)

    pipe.close()

def consumer(pipe):
    while True:
        try:
            item = pipe.recv()
            print(item)
        except EOFError:
            break

if __name__ == '__main__':
    pipe = multiprocessing.Pipe()

    p1 = multiprocessing.Process(target=producer, args=(pipe[0],))
    p2 = multiprocessing.Process(target=consumer, args=(pipe[1],))

    p1.start()
    p2.start()

    p1.join()
    p2.join()

在这个示例代码中,我们创建了一个管道,然后启动了两个进程p1和p2,p1用于执行producer函数,p2用于执行consumer函数。我们在producer函数中向管道中发送数据,然后关闭管道;在consumer函数中,我们不断地从管道中读取数据,直到遇到EOFError异常。

3. 共享内存 进程可以定义共享内存区段,多个进程可以访问同一块内存空间,以实现数据共享。需要使用Value或Array等同步机制。

共享内存是一个非常高效的进程间通信方式,它可以让多个进程访问同一个内存区域,从而达到数据共享的目的。

下面是一个简单的利用共享内存实现进程间通信的示例代码:

import multiprocessing

def producer(shared_value):
    for i in range(10):
        shared_value.value = i

def consumer(shared_value):
    while True:
        print(shared_value.value)

if __name__ == '__main__':
    shared_value = multiprocessing.Value('i', 0)

    p1 = multiprocessing.Process(target=producer, args=(shared_value,))
    p2 = multiprocessing.Process(target=consumer, args=(shared_value,))

    p1.start()
    p2.start()

    p1.join()
    p2.join()

在这个示例代码中,我们定义了两个函数producer和consumer,producer函数用于往共享内存中写数据,consumer函数用于从共享内存中读取数据。我们使用multiprocessing.Value来创建共享内存对象,并将其传递给两个进程。在producer函数中,我们不断地改变共享内存的值,而在consumer函数中,我们循环读取共享内存的值并打印出来。

4. 消息队列(Message Queue) 通过消息队列接口向队列中放入消息,然后再从队列中获取消息,队列将消息传递给其它进程。

5. 信号量(Semaphore) 用于进程间以及同一进程不同线程之间的信号传递,可以发出信号和接收信号。

信号量可以用于多个进程之间的同步控制,包括进程的互斥和进程的同步等功能。

下面是一个简单的利用信号量实现进程间通信的示例代码:

import multiprocessing

def producer(queue, sem):
    for i in range(10):
        sem.acquire()
        queue.put(i)

def consumer(queue, sem):
    while True:
        item = queue.get()
        print(item)
        sem.release()

if __name__ == '__main__':
    queue = multiprocessing.Queue()
    sem = multiprocessing.Semaphore(1)

    p1 = multiprocessing.Process(target=producer, args=(queue, sem))
    p2 = multiprocessing.Process(target=consumer, args=(queue, sem))

    p1.start()
    p2.start()

    p1.join()
    p2.join()

在这个示例代码中,我们定义了两个函数producer和consumer,producer函数用于往队列中写数据,consumer函数用于从队列中读取数据。我们使用multiprocessing.Semaphore来创建一个信号量并设定其初始值为1。在producer函数中,我们通过sem.acquire()方法申请信号量,如果能申请到,则往队列中写数据,否则无限等待;在consumer函数中,我们从队列中读取数据,并通过sem.release()方法释放信号量。

6. 套接字(Socket) 进程间可以通过网络套接字进行通信,就像通过网络接口的客户端和服务器那样。

通过选择适当的通信机制,可以在Python进程间进行数据交换和通信。multiprocessing模块提供了支持进程间通信的各种组件。文章来源地址https://www.toymoban.com/news/detail-843647.html

到了这里,关于Python进程间通信常用的几种方式的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Python保存图像的几种方式

    记录读取和保存图像的几种方式 1.1、使用 cv2 读取图片,注意:opencv打开路径中不能有中文!!! 1.2、使用 rasterio 读取遥感影像 1.3、使用 Image 读取图像 2.1、使用 cv2 保存图片 2.2、使用numpy保存 2.3、使用plt保存 参考: https://blog.csdn.net/xzm961226xzm/article/details/120951317 https://bl

    2024年02月11日
    浏览(14)
  • python - 线程的启动的几种方式

    本文主要给大家介绍python启动线程的四种方式 创建 Thread 对象,然后调用 start() 方法启动线程。 重写 run() 方法,并调用 start() 方法启动线程。 使用ThreadPoolExecutor 类的 submit() 方法提交任务,自动创建线程池并执行任务。 创建进程,然后在进程中启动线程。 以上就是python中启

    2024年02月12日
    浏览(11)
  • 运行 Python 脚本/代码的几种方式

    哈喽大家好,我是咸鱼 我们知道,python 脚本或者说 python 程序其实是一个包含了 python 代码的文件。要让它们实现特定功能,我们需要知道该如何运行(run)它 通过运行 python 代码,我们可以验证脚本/程序是否按照我们的期望执行。这也使我们能够对其进行测试和调试,以便

    2024年02月08日
    浏览(9)
  • python中导入模块/包的几种方式

    一、模块的导入方式 模块就是.py类型的Python文件 导入时不需要.py后缀,直接导入文件名即可 1.利用import直接导入: 语法:import module_name 使用方式:module_name.class_name或者module.func_name 2.利用import导入模块并设置一个别名 语法:import module_name as XXX 使用方式:XXX.class_name或者X

    2024年01月22日
    浏览(11)
  • python创建虚拟环境的几种方式

    venv是Python的虚拟环境管理工具,它可以创建独立的Python环境,让不同项目使用不同的Python版本和依赖库,避免版本冲突和依赖冲突问题。使用Python venv可以方便地创建、激活、退出、删除虚拟环境,以及在虚拟环境中安装、升级、卸载包等操作。   以下是使用Venv创建和管理

    2024年02月02日
    浏览(21)
  • python发送邮件的几种常用方法

    第一种是最常见的,smtp发送 第二种是用outlook发送的,这个大家借鉴使用 第三种是正文需要用到表格的,我在这里给大家一个示例,具体表格怎么改自行发挥

    2024年02月16日
    浏览(14)
  • Python Requests使用Cookie的几种方式

    这篇文章将总结 Python Requests库中接口请求时使用Cookie的几种方式,文章使用 Postman 官网提供的接口进行演示 https://postman-echo.com 通过headers参数使用cookie,key为Cookie,值为使用;拼接的 cookie_name=cookie_value 字符串 输出如下: 通过cookies参数使用cookie,cookies 值以字典形式提供,

    2024年02月13日
    浏览(9)
  • Python调用API接口的几种方式

    Python调用API接口的几种方式 相信做过自动化运维的同学都用过API接口来完成某些动作。API是一套成熟系统所必需的接口,可以被其他系统或脚本来调用,这也是自动化运维的必修课。 本文主要介绍python中调用API的几种方式,下面是python中会用到的库。 - urllib2 - httplib2 - pycu

    2024年02月12日
    浏览(11)
  • 【Python】导入Excel数据表的几种方式

    如何导入csv、xlsx格式的Excel; 一张数据表里有多个sheet页,如何获取所有sheet页名字,并导入每张sheet页; 1. 导入CSV格式的Excel表: 2. 导入xlsx格式的Excel表: 如果Excel表里只有一个sheet页: 如果Excel表里有多个sheet页: 如果Excel表里sheet页过多:

    2024年02月03日
    浏览(17)
  • Linux查看进程实际占用内存的几种方式

    方式一 top -p pid RES :72296,使用的内存为72296kb %MEM:1.9,进程占用了总内存的1.9% 方式二 ps -aux | grep pid 显示其他用户启动的进程(a) 查看系统中属于自己的进程(x) 启动这个进程的用户和它启动的时间(u) 方式三 cat /proc/pid/status

    2024年02月11日
    浏览(10)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包