Patent ID: 8595743

Claim:
A system comprising: a plurality of processors, receiving input stream of data from a source; a queue manager that: receives a scheduling graph from an analyzer, said scheduling graph comprising executable elements and relationships between said executable elements, said relationships comprising data dependency relationships; from said scheduling graph, identifies a first executable element that receives said input stream from the source; identifies a first set of executable elements comprising a plurality of executable elements being executed downstream from said first executable element; and identifies a second set of executable elements comprising a plurality of executable elements being executed upstream from said first executable element; schedules said second set of executable elements, said second set of executable elements being executed at an elevated priority by preempting other executable elements; and schedules said first set of executable elements such that a process scheduler causes said first set of executable elements to process said input stream of data; a load manager that: monitors performance of said executable elements, by when processing of said input stream of data is operating at maximum capacity, continues said monitoring; when processing of said input stream is not operating at maximum capacity, identifies a second executable element downstream from said first executable element, said second executable element being a bottleneck for processing output from said first executable element; and allocates additional processing resources to said second executable element until said executable elements is operating at full capacity.