您的位置: 首页 > 生活常识 >

demo程序是干什么的(python中demo是什么)

100次浏览     发布时间:2024-08-08 11:31:00    

DEMO是"demonstration"的缩写。DEMO的中文含意为“示范”、“展示”、“样片”、“样稿”、“原型”,常被用来称呼具有示范或展示功能及意味的事物。

例:python简单分布式demo

A服务器是master,B服务器为worker。

A服务器上执行taskManger.py

# coding:utf-8

import random,time,Queue

from multiprocessing.managers import BaseManager

#实现第一步:建立task_queue和result_queue,用来存放任务和结果

task_queue=Queue.Queue()

result_queue=Queue.Queue()

class Queuemanager(BaseManager):

pass

#实现第二步:把创建的两个队列注册在网络上,利用register方法,callable参数关联了Queue对象,

# 将Queue对象在网络中暴露

Queuemanager.register('get_task_queue',callable=lambda:task_queue)

Queuemanager.register('get_result_queue',callable=lambda:result_queue)

#实现第三步:绑定端口8001,设置验证口令‘qiye’。这个相当于对象的初始化

manager=Queuemanager(address=('',8001),authkey='lsf')

#实现第四步:启动管理,监听信息通道

manager.start()

#实现第五步:通过管理实例的方法获得通过网络访问的Queue对象

task=manager.get_task_queue()

result=manager.get_result_queue()

#实现第六步:添加任务

for url in ["ImageUrl_"+str(i) for i in range(10)]:

print 'put task %s ...' %url

task.put(url)

#获取返回结果

print 'try get result...'

for i in range(10):

print 'result is %s' %result.get(timeout=10)

#关闭管理

manager.shutdown()

B服务器上执行worker的脚本taskWorker.py

#coding:utf-8

import time

from multiprocessing.managers import BaseManager

# 创建类似的QueueManager:

class QueueManager(BaseManager):

pass

# 实现第一步:使用QueueManager注册获取Queue的方法名称

QueueManager.register('get_task_queue')

QueueManager.register('get_result_queue')

# 实现第二步:连接到服务器:

server_addr = '127.0.0.1'

print('Connect to server %s...' % server_addr)

# 端口和验证口令注意保持与服务进程设置的完全一致:

m = QueueManager(address=(server_addr, 8001), authkey='lsf')

# 从网络连接:

m.connect()

# 实现第三步:获取Queue的对象:

task = m.get_task_queue()

result = m.get_result_queue()

# 实现第四步:从task队列取任务,并把结果写入result队列:

while(not task.empty()):

image_url = task.get(True,timeout=5)

print('run task download %s...' % image_url)

time.sleep(1)

result.put('%s--->success'%image_url)

 处理结束:

print('worker exit.')


相关文章

沃克拉壁挂炉维修电话号码24小时服务热线(沃克拉壁挂炉壁挂炉遥控器信号弱咋增强信号)

沃克拉壁挂炉维修电话号码24小时服务热线(沃克拉壁挂炉壁挂炉遥控器信号弱咋增强信号)常见故障与维修指南沃克拉壁挂炉维修电话号码24小时服务热线(沃克拉壁挂炉壁挂炉遥控器信号弱咋增强信号)在家庭采暖领域中占据着举足轻重的地位,然而,当它遭遇故障时,众多用户或许会陷入手足无措的困境。沃克拉壁挂炉维修
2025-12-13 23:59:34

沃乐夫壁挂炉各市区24小时售后维修客服热线(沃乐夫壁挂炉壁挂炉烟道堵塞导致废气倒灌咋解决)

沃乐夫壁挂炉各市区24小时售后维修客服热线(沃乐夫壁挂炉壁挂炉烟道堵塞导致废气倒灌咋解决),作为冬季采暖的可靠伙伴,在我们的日常生活中常常发挥着关键作用。它宛如一位默默守护的卫士,为我们抵御严寒,带来温暖与舒适。然而,就像任何其他设备一样,它偶尔也会遭遇一些小小的故障,沃乐夫壁挂炉各市区24小时售
2025-12-13 23:54:13

万家乐壁挂炉全国各区维修服务咨询电话号码是多少?(万家乐壁挂炉壁挂炉地暖管漏水问题咋解决呢)

万家乐壁挂炉全国各区维修服务咨询电话号码是多少?(万家乐壁挂炉壁挂炉地暖管漏水问题咋解决呢)在长期持续的使用过程中,不可避免地可能会遭遇多种多样的故障。万家乐壁挂炉全国各区维修服务咨询电话号码是多少?(万家乐壁挂炉壁挂炉地暖管漏水问题咋解决呢)售后电话24小时人工服务电话400-605-8619
2025-12-13 23:51:35

基诺德热水器售后服务电话24小时客服(基诺德热水器燃气热水器风机转速不稳定咋修)

基诺德热水器售后服务电话24小时客服(基诺德热水器燃气热水器风机转速不稳定咋修)热水器的售后服务通常涵盖了以下多个重要方面:基诺德热水器售后服务电话24小时客服(基诺德热水器燃气热水器风机转速不稳定咋修)热水器售后网点24小时服务热线电话400-605-8619安装服务:一支具备丰富经验和专业
2025-12-13 23:46:44

卓盾保险箱全国各售后服务点热线号码(卓盾保险箱保险柜电子系统损坏怎么办)

卓盾保险箱全国各售后服务点热线号码(卓盾保险箱保险柜电子系统损坏怎么办)故障与售后服务指南卓盾保险箱全国各售后服务点热线号码(卓盾保险箱保险柜电子系统损坏怎么办)24小时服务热线全国售后服务电话400-605-8619一、卓盾保险箱全国各售后服务点热线号码(卓盾保险箱保险柜电子系统损坏怎么
2025-12-13 23:43:08

多吉保险箱全国24小时各售后受理客服中心(多吉保险箱保险柜没有电了,怎样才能打开)

《多吉保险箱全国24小时各售后受理客服中心(多吉保险箱保险柜没有电了,怎样才能打开)故障处理与售后服务指南》,采用模块化结构便于阅读:多吉保险箱全国24小时各售后受理客服中心(多吉保险箱保险柜没有电了,怎样才能打开)售后网点全国各市售后服务电话400-605-8619一、多吉保险箱全国24
2025-12-13 23:38:13

网站内容来自网络,如有侵权请联系我们,立即删除!
Copyright © 蜜柚百科 琼ICP备2025060580号-2