Python漫衍式历程中你会碰着的坑

在task_worker.py中修改如下：

#！/user/bin/pytthon 
# -*- coding:utf-8 -*- 
# @Time: 2018/3/3 16:46 
# @Author: lichexo 
# @File: task_worker.py 
# task_worker.py 
import time, sys, queue 
from multiprocessing.managers import BaseManager 
# 建设相同的QueueManager: 
class QueueManager(BaseManager): 
 pass 
# 因为这个QueueManager只从收集上获取Queue，以是注册时只提供名字: 
QueueManager.register('get_task_queue') 
QueueManager.register('get_result_queue') 
# 毗连随处事器，也就是运行task_master.py的呆板: 
server_addr = '127.0.0.1' 
print('Connect to server %s...' % server_addr) 
# 端口和验证码留意保持与task_master.py配置的完全同等: 
m = QueueManager(address=(server_addr, 5000), authkey=b'abc') 
# 从收集毗连: 
m.connect() 
# 获取Queue的工具: 
task = m.get_task_queue() 
result = m.get_result_queue() 
# 从task行列取使命,并把功效写入result行列: 
for i in range(10): 
 try: 
 n = task.get(timeout=1) 
 print('run task %d * %d...' % (n, n)) 
 r = '%d * %d = %d' % (n, n, n*n) 
 time.sleep(1) 
 result.put(r) 
 except queue.Empty: 
 print('task queue is empty.') 
# 处理赏罚竣事: 
print('worker exit.') 

先运行task_master.py,然后再运行task_worker.py

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!