Effective scheduling of producer-consumer processes in a multi-processor system

A non-transitory computer-readable medium containing executable program instructions executed by a processor, comprising:

• program instructions that execute a producer-consumer pair of processes at a multi-core processor system;
• program instructions that execute a producer process of the producer-consumer pair on a first processing core of the multi-core processor system to produce data elements, wherein a first portion of the data elements is cached in a first cache of the first processing core that references data in a memory shared by the producer-consumer pair;
• program instructions that, in response to producing the first portion of the data elements cached in the first cache by the producer process, schedule a consumer process of the producer-consumer pair to execute on the first processing core and execute the consumer process on the first processing core to consume the first portion of the data elements cached at the first processing core;
• program instructions that move the producer process to execute on a second processing core of the multi-core system to produce a second portion of the data elements, wherein the second portion of the data elements are cached in a second cache of the second processing core;
• and
• program instructions that, in response to producing the second portion of the data elements cached in the second cache, schedule the consumer process to execute on the second processing core and execute the consumer process on the second processing core to consume the second portion of the data elements cached at the second processing core.

A system for data processing in a producer-consumer environment on a multi-core processor system, comprising:

• means for executing a producer-consumer pair of processes at the multi-core processor system;
• and
• means for executing a producer process of the producer-consumer pair on a first processing core of the multi-core processor system to produce data elements, wherein a first portion of the data elements is cached in a first cache of the first processing core that references data in a memory shared by the producer-consumer pair;
• means for, in response to producing the first portion of the data elements cached in the first cache by the producer process of the producer-consumer pair, scheduling a consumer process of the producer-consumer pair to execute on the first processing core and to execute the consumer process on the first processing core to consume the first portion of the data elements cached at the first processing core;
• means for moving the producer process to execute on a second processing core of the multi-core system to produce a second portion of the data elements, wherein the second portion of the data elements are cached in a second cache of the second processing core;
• and
• means for scheduling the consumer process to execute on the second processing core and means for executing the consumer process on the second processing core to consume the second portion of the data elements cached at the second processing core in response to producing the second portion of the data elements cached in the second cache.

A multi-core system having a plurality of processing cores for data processing in producer-consumer environments, comprising:

• a first processing core, of the plurality of processing cores, configured to execute a producer process and a consumer process of a producer-consumer pair, the producer process configured to produce data elements;
• and
• a scheduler module configured to:
• in response to producing the first portion of the data elements cached in the first cache by the producer process, schedule a consumer process of the producer-consumer pair to execute on the first processing core, of the plurality of processing cores, to consume the first portion of the data elements cached at the first processing core,
• move execution of the producer process to a second processing core to produce a second portion of the data elements, and
• schedule the consumer process to execute on the second processing core, in response to producing the second portion of the data elements.