利用TCP连接执行了不同的端口并行线程

Question

我想执行这个python脚本实现分布式计算协议。目前，该执行的功能顺序一个接一个。我想正如下面的语句中提到的能够运行的所有进程并行在不同的端口，而不是** multiprocessing.Manager（）。队列（）的**，但我不知道我应该如何去了解。任何先声夺人，将不胜感激导致我在正确的方向

import multiprocessing
from threading import Thread

class Process(Thread):
  def __init__(self, env, id):
    super(Process, self).__init__()
    self.inbox = multiprocessing.Manager().Queue()
    self.env = env
    self.id = id

  def run(self):
    try:
      self.body()
      self.env.removeProc(self.id)
    except EOFError:
      print "Exiting.."

  def getNextMessage(self):
    return self.inbox.get()

  def sendMessage(self, dst, msg):
    self.env.sendMessage(dst, msg)

  def deliver(self, msg):
    self.inbox.put(msg)

Answer 1

我能够通过实施简单的套接字编程代替队列的由以下Python文档，然后进行超过这些插槽可能消息的通信并行运行模式此代码。