FilesExpand file tree

 master

/

test36.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

39 lines (32 loc) · 1.03 KB

 master

/

test36.py

Top

File metadata and controls

• Code
• Blame

39 lines (32 loc) · 1.03 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

#!/usr/bin/env python3

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

'处理分布式进程发送的数据'

__author__ = 'sergiojune'

from multiprocessing.managers import BaseManager

import time, queue

class QueueManager(BaseManager):

pass

# 注册到网络上

QueueManager.register('post_task_queue') # 由于只是从网络上获取queue，所以不需要写callable方法

QueueManager.register('result_task_queue')

# 连接到网络

address = '127.0.0.1' # 这个是网络地址

manager = QueueManager(address=(address, 500), authkey=b'abc') # 这些必须与发送的一致，要不会连不上

# 连接

manager.connect()

# 获取queue

post = manager.post_task_queue()

result = manager.result_task_queue()

# 处理数据

print('tyr get value')

for x in range(10):

try:

v = post.get(timeout=10)

print('get value %d' % v)

r = v*v

print('put value %d to result' % r)

time.sleep(1)

result.put(r)

except queue.Empty as e:

print('Queue is empty')

print('work exit')