python中demo是什么-Python教程

例：python简略散布式demo（保举学习：Python视频教程）

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.')

更多Python相干技巧文章，请拜访Python教程栏目进行学习！

以上就是python中demo是甚么的具体内容，更多请存眷资源魔其它相干文章！