GeezerVison is showing github.com — python_test/test35.py at master · Hanlen520/python_test

Expand file tree

test35.py

Copy path

More file actions

Latest commit

History

66 lines (48 loc) · 1.69 KB

test35.py

Copy path

File metadata and controls

66 lines (48 loc) · 1.69 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

#!/usr/bin/env python3

# -*- coding: utf-8 -*-

'练习分布式进程 '

__author__ = 'sergiojune'

import queue, random

from multiprocessing.managers import BaseManager

# 此文件用来发送和接受结果，test36.py用于处理结果

# 创建通信工具

# 发送任务

post_task = queue.Queue()

# 接受结果

result_task = queue.Queue()

class QueueManager(BaseManager):

pass

# 定义的函数解决下面的坑

def posttq():

return post_task

def resulttq():

return result_task

def start():

# 注册任务

# 这里有个坑，在window系统下callable不能为匿名函数，原因是不能被序列化，所以在这里我们需要定义函数

QueueManager.register('post_task_queue', callable=posttq) # 第一个参数为注册名字

QueueManager.register('result_task_queue', callable=resulttq)

# 绑定窗口，设置验证码

manager = QueueManager(address=('127.0.0.1', 500), authkey=b'abc') # 第一个参数为地址和端口，第二个参数为验证码，防止别人骚扰

# 启动管理

manager.start()

# 通过管理器获取通信

post = manager.post_task_queue()

result = manager.result_task_queue()

# 进行发送数据

print('try post data')

for x in range(10):

n = random.randint(1, 1000000)

print('put %d' % n)

post.put(n)

# 接受结果

print('try get result')

for x in range(10):

# timeout表示超时获取数的最长时间

value = result.get(timeout=10)

print('get result', value)

# 关闭管理器

manager.shutdown()

print('master end')

if __name__ == '__main__':

start()