溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶(hù)服務(wù)條款》

python中demo有什么用

發(fā)布時(shí)間:2020-11-16 14:10:04 來(lái)源:億速云 閱讀:457 作者:小新 欄目:編程語(yǔ)言

這篇文章將為大家詳細(xì)講解有關(guān)python中demo有什么用,小編覺(jué)得挺實(shí)用的,因此分享給大家做個(gè)參考,希望大家閱讀完這篇文章后可以有所收獲。

DEMO是"demonstration"的縮寫(xiě)。DEMO的中文含意為“示范”、“展示”、“樣片”、“樣稿”、“原型”,常被用來(lái)稱(chēng)呼具有示范或展示功能及意味的事物。

例:python簡(jiǎn)單分布式demo

A服務(wù)器是master,B服務(wù)器為worker。

A服務(wù)器上執(zhí)行taskManger.py

# coding:utf-8

import random,time,Queue
from multiprocessing.managers import BaseManager
#實(shí)現(xiàn)第一步:建立task_queue和result_queue,用來(lái)存放任務(wù)和結(jié)果

task_queue=Queue.Queue()
result_queue=Queue.Queue()

class Queuemanager(BaseManager):
    pass
#實(shí)現(xiàn)第二步:把創(chuàng)建的兩個(gè)隊(duì)列注冊(cè)在網(wǎng)絡(luò)上,利用register方法,callable參數(shù)關(guān)聯(lián)了Queue對(duì)象,
# 將Queue對(duì)象在網(wǎng)絡(luò)中暴露
Queuemanager.register('get_task_queue',callable=lambda:task_queue)
Queuemanager.register('get_result_queue',callable=lambda:result_queue)

#實(shí)現(xiàn)第三步:綁定端口8001,設(shè)置驗(yàn)證口令‘qiye’。這個(gè)相當(dāng)于對(duì)象的初始化
manager=Queuemanager(address=('',8001),authkey='lsf')

#實(shí)現(xiàn)第四步:?jiǎn)?dòng)管理,監(jiān)聽(tīng)信息通道
manager.start()

#實(shí)現(xiàn)第五步:通過(guò)管理實(shí)例的方法獲得通過(guò)網(wǎng)絡(luò)訪(fǎng)問(wèn)的Queue對(duì)象
task=manager.get_task_queue()
result=manager.get_result_queue()

#實(shí)現(xiàn)第六步:添加任務(wù)
for url in ["ImageUrl_"+str(i) for i in range(10)]:
    print 'put task %s ...' %url
    task.put(url)
#獲取返回結(jié)果
print 'try get result...'
for i in range(10):
    print 'result is %s' %result.get(timeout=10)
#關(guān)閉管理
manager.shutdown()

B服務(wù)器上執(zhí)行worker的腳本taskWorker.py

#coding:utf-8
import time
from multiprocessing.managers import BaseManager


# 創(chuàng)建類(lèi)似的QueueManager:
class QueueManager(BaseManager):
    pass

# 實(shí)現(xiàn)第一步:使用QueueManager注冊(cè)獲取Queue的方法名稱(chēng)
QueueManager.register('get_task_queue')
QueueManager.register('get_result_queue')
# 實(shí)現(xiàn)第二步:連接到服務(wù)器:
server_addr = '127.0.0.1'
print('Connect to server %s...' % server_addr)
# 端口和驗(yàn)證口令注意保持與服務(wù)進(jìn)程設(shè)置的完全一致:
m = QueueManager(address=(server_addr, 8001), authkey='lsf')
# 從網(wǎng)絡(luò)連接:
m.connect()
# 實(shí)現(xiàn)第三步:獲取Queue的對(duì)象:
task = m.get_task_queue()
result = m.get_result_queue()
# 實(shí)現(xiàn)第四步:從task隊(duì)列取任務(wù),并把結(jié)果寫(xiě)入result隊(duì)列:
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)

# 處理結(jié)束:
print('worker exit.')

關(guān)于python中demo有什么用就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò),可以把它分享出去讓更多的人看到。

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀(guān)點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI