Coordinated processing of data by networked computing resources

Inventors: Walter Michael Pitio (Morganville, NJ); Philip Iannaccone (New York, NY); Daniel Aisen (New York, NY); Bradley Katsuyama (New York, NY); Robert Park (New York, NY); John Schwall (New York, NY); Richard Steiner (Wyckoff, NJ); Allen Zhang (Princeton, NJ); Thomas L. Popejoy (New York, NY)

Assignee: ROYAL BANK OF CANADA

H04L67/10 G06Q40/04 H04L43/0852 H04L47/283 H04L47/70 H04L67/62 H04L43/0858 H04L43/0864

View Patent ↗

Loading inventors, assignments & file history…

Monitor This Case

Get email alerts when status or documents change.

Order Certified Copies

Most orders are placed with the USPTO same day — all within 24 business hours.

Order via The Patent Place →

Pre-filled with this patent's details

Quick Facts

Patent No.: US 12712940
App. No.: 18/942,948
Granted: Aug 18, 2026
Kind: B2

External Links

USPTO Patent Center↗ Full Patent PDF↗

Abstract

Systems, methods, and computer-readable media for coordinating processing of data by multiple networked computing resources include monitoring data associated with a plurality of networked computing resources, and coordinating the routing of data processing segments to the networked computing resources.

Claims (41)

1 . A system for coordinating processing of data by multiple networked computing resources, the system comprising at least one processor configured to:

observe data associated with a plurality of networked computing resources, the observed data including order load data associated with at least one of the plurality of networked computing resources, and parameters of a dynamically-varying delay on data processing segments routed to the at least one of the plurality of networked computing resources during periods of the order loads; wherein observing the data associated with the plurality of networked computing resources includes:

determining components of a latency associated with routing a data processing segment to one of the plurality of networked computing resources, wherein determining the components of the latency is based on differences in latencies associated with routing different types of data processing segments to the one of the plurality of networked computing resources;

receive from one or more data sources signals representing instructions for execution of at least one data process executable by the plurality of networked computing resources;

based on the observed data including the parameters of the dynamically-varying delay on data processing segments for the at least one of the plurality of networked computing resources:

divide the at least one data process into at least one data processing segment, each data processing segment to be routed to one of the plurality of networked computing resources, wherein dividing the at least one data process includes selecting to which of the plurality of networked computing resources at least one of the plurality of data processing segments is to be routed;

determine a plurality of timing parameters, each of the plurality of timing parameters to be associated with a corresponding one of the plurality of data processing segments, the plurality of timing parameters determined to cause coordinated execution of the at least one data processing segment by the plurality of networked computing resources based at least in part on the parameters of the dynamically-varying delay and current order load data associated with the plurality of networked computing resources; and

route the at least one data processing segment to the plurality of corresponding networked computing resources in a timing sequence based on the timing parameters.

2 . The system of claim 1 , wherein the components of the latency include at least one range of delay lengths introduced by at least one of the plurality of networked computing resources.

3 . The system of claim 1 , dividing the at least one data process into at least one data processing segment includes or determining the plurality of timing parameters is based on a type of the at least one data process.

4 . The system of claim 1 , wherein the at least one processor is configured to: determine whether liquidity in addition to posted liquidity is historically available at a particular networked computing resource,

and wherein dividing the at least one data process includes dividing the at least one data process into at least two data processing segments to be routed to the particular networked computing resource, the at least two data processing segments having timing parameters to target the posted available trade liquidity and the additional liquidity.

5 . The system of claim 1 , wherein the order load data includes a volume of data processing segments at a particular networked computing resource.

6 . The system of claim 5 , wherein the volume of data processing segments includes a volume of a type of data process corresponding to a type of the at least one data processing segment.

7 . The system of claim 6 , wherein dividing the at least one data process into at least one data processing segment includes or determining the plurality of timing parameters is based on a volatility level and the historical execution latencies.

8 . A method for coordinating processing of data by multiple networked computing resources, the method comprising:

observing data associated with a plurality of networked computing resources, the observed data including order load data associated with at least one of the plurality of networked computing resources, and parameters of a dynamically-varying delay on data processing segments routed to the at least one of the plurality of networked computing resources during periods of the order loads;

wherein observing the data associated with the plurality of networked computing resources includes: determining components of a latency associated with routing a data processing segment to one of the plurality of networked computing resources, wherein determining the components of the latency is based on differences in latencies associated with routing different types of data processing segments to the one of the plurality of networked computing resources;

receiving from one or more data sources signals representing instructions for execution of at least one data process executable by the plurality of networked computing resources;

based on the observed data including the parameters of the dynamically-varying delay on data processing segments for the at least one of the plurality of networked computing resources:

dividing the at least one data process into at least one data processing segment, each data processing segment to be routed to one of the plurality of networked computing resources, wherein dividing the at least one data process includes selecting to which of the plurality of networked computing resources at least one of the plurality of data processing segments is to be routed;

determining a plurality of timing parameters, each of the plurality of timing parameters to be associated with a corresponding one of the plurality of data processing segments, the plurality of timing parameters determined to cause coordinated execution of the at least one data processing segment by the plurality of networked computing resources based at least in part on the parameters of the dynamically-varying delay and current order load data associated with the plurality of networked computing resources; and

routing the at least one data processing segment to the plurality of corresponding networked computing resources in a timing sequence based on the timing parameters.

9 . The method of claim 8 , wherein the components of the latency include at least one range of delay lengths introduced by at least one of the plurality of networked computing resources.

10 . The method of claim 8 , wherein dividing the at least one data process into at least one data processing segment includes or determining the plurality of timing parameters is based on a type of the at least one data process.

11 . The method of claim 8 , wherein the method includes:

determining whether liquidity in addition to posted liquidity is historically available at a particular networked computing resource,

12 . The method of claim 8 , wherein the order load data includes a volume of data processing segments at a particular networked computing resource.

13 . The method of claim 12 , wherein the volume of data processing segments includes a volume of a type of data process corresponding to a type of the at least one data processing segment.

14 . The method of claim 13 , wherein dividing the at least one data process into at least one data processing segment includes or determining the plurality of timing parameters is based on a volatility level and the historical execution latencies.

15 . A non-transitory computer-readable medium having stored thereon instructions which, when executed by at least one processor, configure the at least one processor to:

receive from one or more data sources signals representing instructions for execution of at least one data process executable by the plurality of networked computing resources;

based on the observed data including the parameters of the dynamically-varying delay on data processing segments for the at least one of the plurality of networked computing resources:

route the at least one data processing segment to the plurality of corresponding networked computing resources in a timing sequence based on the timing parameters.

16 . The non-transitory computer-readable medium of claim 15 wherein the components of the latency include at least one range of delay lengths introduced by at least one of the plurality of networked computing resources.

17 . The non-transitory computer-readable medium of claim 15 , wherein the order load data includes a volume of a type of data process corresponding to a type of the at least one data processing segment.