任务描述:
使用Python+pyzmq编写程序,实现任务并行处理。服务端推送大量整数,中间任意多个工作进程负责接收这些整数、判断是否为素数然后把处理结果推送给客户端,客户端接收判断结果然后显示哪些整数是素数。
技术原理图:
服务端程序:
中间任务处理程序:
客户端程序:
运行界面:
在运行上面的程序时,是手动启动了多个中间工作进程,稍显笨重。在实际应用中可以结合多进程编程技术,直接创建多个工作进程,也可以在每台中间机器上启动多个进程进一步加快速度。只需要把中间的程序pyzmq_并行管道_workers.py改成下面的样子即可。
运行界面如图所示: