- # 连接到服务器, 也就是运行 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=babc)
- # 从网络连接:
- 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.)
来源: http://www.bubuko.com/infodetail-2514663.html