Data flow management for computational loads

A computer-implemented method comprising:

• producing data at a producer node of a data pipeline for processing vehicle data characterizing an operation of a vehicle;
• selecting a data buffer from a plurality of shared data buffers, the selected data buffer being shared by at least two consumer nodes of the data pipeline;
• writing the data to the selected data buffer;
• receiving event data at an event producer node of the data pipeline;
• writing the event data from the event producer node to at least one control buffer of a plurality of shared control buffers that are shared by the at least two consumer nodes;
• reading the event data from the at least one control buffer at each of the at least two consumer nodes;
• and
• executing synchronized consumption of the data from the selected data buffer by each of the at least two consumer nodes, based on the event data, to thereby complete the processing and characterize the operation of the vehicle.

A vehicle comprising:

• a chassis;
• a frame mounted on the chassis;
• a motor mounted within the frame;
• a plurality of sensors mounted on the vehicle and configured to generate sensor data characterizing an environment of the vehicle;
• at least one memory including instructions;
• and
• at least one processor that is operably coupled to the at least one memory and that is arranged and configured to execute instructions that, when executed, cause the at least one processor to:
• produce data at a producer node of a data pipeline for processing vehicle data characterizing an operation of a vehicle;
• select a data buffer from a plurality of shared data buffers, the selected data buffer being shared by at least two consumer nodes of the data pipeline;
• write the data to the selected data buffer;
• receive event data at an event producer node of the data pipeline;
• write the event data from the event producer node to at least one control buffer of a plurality of shared control buffers that are shared by the at least two consumer nodes;
• read the event data from the at least one control buffer at each of the at least two consumer nodes;
• and
• execute synchronized consumption of the data from the selected data buffer by each of the at least two consumer nodes, based on the event data, to thereby complete the processing and characterize the operation of the vehicle.