使用TCP连接在不同端口上执行并行线程

Question

我试图执行这个python脚本来实现分布式计算协议。目前，它依次执行函数。我希望能够在不同的端口上并行运行所有进程，而不是**多处理管理器（）.Queue（）**正如下面的语句中所提到的，但我不知道该怎么做。如果能给我一个好的开端，我将不胜感激

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文档执行队列，然后通过这些套接字实现消息通信。你知道吗