CPC G06F 3/0656 (2013.01) [G06F 3/0604 (2013.01); G06F 3/0679 (2013.01)] | 20 Claims |
1. A computer program product, the computer program product being tangibly embodied on a non-transitory computer-readable storage medium and comprising instructions that, when executed by at least one computing device, are configured to cause the at least one computing device 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.
|