| CPC G06F 9/505 (2013.01) [G06F 8/65 (2013.01); G06F 8/77 (2013.01); G06F 9/5072 (2013.01)] | 20 Claims |

|
1. A computer-implemented method for lock-free data aggregation, the method comprising:
concurrently producing new data at a plurality of producer nodes of a distributed system comprising two or more producer nodes, a consumer node, and a global view comprising a hierarchical binary tree of cell addresses, wherein each of the two or more producer nodes comprises a local view representation of the global view, and wherein the global view further comprises a height of log2N and each local view comprises a depth between 0 and log2N, where N is the number of producer nodes;
responsive to producing the new data, updating the local views of the two or more producer nodes with their respective new data and a local timestamp and, if the local timestamp is greater than a global timestamp, flipping a pointer in a cell address of the global view to point to the new data in the local view of the respective producer.
|