0

我必须在节点 A、B、C（D、E...）中一个接一个地运行几个计算。每个节点对应一个具有计算方法的类。在以下方案中，Ax、Bx、Cx 是 A、B、C 的实例，并允许运行计算、创建一些图形等。 数据流

我有以下要求：

  • 我有一个分布式系统（例如云），我希望在A中的数据输出后处理B1中的数据等等（节点必须同步）；
  • 相似节点中的所有计算可以并行执行；
  • 每个节点中的计算结果必须在某个时候保存和加载。这在 A 中的数据已被计算并且之后整个系统关闭的情况下很有用。我希望能够康复。目标也是能够通过重新运行系统的过去状态来执行一些维护（例如，用于错误跟踪）；
  • 我希望能够监控系统的当前状态。

我打算采用状态设计模式，但它似乎还不够，或者我没有正确的实现想法。

这本身就是一个巨大的主题，所以我很乐意从设计模式、多线程处理、API、中间件等方面获得想法。

（顺便说一句，我用的是Python，但我觉得提的意义不大）

4

1 回答 1

1

python 多任务处理的一个成功设计是队列链模型。如果你的数量有限steps(A,B,Cs)。然后可以将每个任务推送到队列中，一旦排队的任务完成，队列就可以发出完成信号。从而可以保存数据并将其推送到后续队列中。一份相关文件。

查看 python 恶魔线程以管理线程生命周期。

于 2013-10-13T10:54:15.843 回答