针对循环数据流的基于可到达性的协调

摘要

各实施例提供了与涉及现实世界系统(诸如社交网络系统、路标/GPS系统等)的数据的大规模集合一起工作的技术。该技术使用协调时钟协议执行增量、迭代和交互并行计算，其应用于在循环图形中调度计算和管理诸如存储器和网络资源等的资源，循环图形包括从在数据集合中的差异上执行计算的差分数据流模型得到的那些。

主权项

一种方法，包括：通过以下跟踪计算的进展：将要在计算中被处理的多个数据项的每一个与数据流图形的顶点相关联，所述数据流图形表示单个程序；将要在计算中被处理的多个数据项的每一个与时戳相关联，所述时戳对应于其中数据项在所述计算中被创建的次序；存储与每个数据项相关联的顶点－时戳对；以及对与每个顶点－时戳对相关联的要被处理的数据项的数量进行计数；以及由至少一个处理器进行通信，所述处理器异步发送一个或多个消息，所述消息包括与至少一个顶点－时戳对相关联的多个要被处理的数据项。