0
点赞
收藏
分享

微信扫一扫

Python+ZeroMQ开发并行处理程序


任务描述:

使用Python+pyzmq编写程序,实现任务并行处理。服务端推送大量整数,中间任意多个工作进程负责接收这些整数、判断是否为素数然后把处理结果推送给客户端,客户端接收判断结果然后显示哪些整数是素数。

技术原理图:

Python+ZeroMQ开发并行处理程序_python

 

服务端程序:

Python+ZeroMQ开发并行处理程序_网络编程_02

 

中间任务处理程序:

Python+ZeroMQ开发并行处理程序_Python_03

 

客户端程序:

Python+ZeroMQ开发并行处理程序_并行处理程序_04

 

运行界面:

Python+ZeroMQ开发并行处理程序_Python_05

 

在运行上面的程序时,是手动启动了多个中间工作进程,稍显笨重。在实际应用中可以结合多进程编程技术,直接创建多个工作进程,也可以在每台中间机器上启动多个进程进一步加快速度。只需要把中间的程序pyzmq_并行管道_workers.py改成下面的样子即可。

Python+ZeroMQ开发并行处理程序_网络编程_06

 

运行界面如图所示:

Python+ZeroMQ开发并行处理程序_python_07

 

公众号“Python小屋”


举报

相关推荐

0 条评论