Task concurrency limiter

• US 9,092,258 B2
• Filed: 12/11/2012
• Issued: 07/28/2015
• Est. Priority Date: 12/11/2012
• Status: Active Grant

• Current Assignee: Bank of America Corp.
• Original Assignee: Bank of America Corp.
• Inventors: Fiacco, Daniel M., Drewek, Nicholas J., Mohan, Dineshkumar, Alaguvel, Senthilkumaran, Muthuvaithyalingam, Senthil
• Primary Examiner(s): Bullock, Jr., Lewis A
• Assistant Examiner(s): Ashley, Bruce S
• Application Number:
  US13/710,545
• Publication Number:
  US 20140165067A1
• Time in Patent Office: 959 Days
• Field of Search: None
• US Class Current: 1/1
• CPC Class Codes: G06F 2209/483 Multiproc
• CPC Class Codes: G06F 9/4843 by program, e.g. task dispatcher, supervisor, operating system

Abstract

In an exemplary embodiment, a method includes intercepting a first task sent from a task scheduler of a first computing system to a second computing system. A number of active tasks initiated by the task scheduler that are being performed by the second computing system is determined. The sending of the first task to the second computing system is delayed in response to a determination that the number of active tasks being performed by the second computing system is greater than or equal to a predetermined task limit associated with the second computing system. The first task is sent to the second computing system in response to a determination that the number of active tasks being performed by the second computing system is less than the predetermined task limit associated with the second computing system.

Claims

1. An apparatus, comprising:

one or more processors operable to;

intercept, via a shell script executed through a command line interface of the apparatus, a first task sent from a task scheduler, the first task specifying one or more actions to be performed and not specifying a computing system for performing the one or more actions;

select, using the shell script, a first computing system to perform the first task, the first computing system coupled to the apparatus via a network;

determine, using the shell script, whether the first computing system is subject to a first concurrency evaluation;

determine, via the shell script, a number of active tasks initiated by the task scheduler that are being performed by the first computing system;

upon a determination that the first computing system is subject to the first concurrency evaluation, determine, using the shell script, whether the number of active tasks being performed by the first computing system is greater than or equal to a first predetermined task limit;

upon a determination that the number of active tasks being performed by the first computing system is less than the first predetermined task limit associated with the first computing system, facilitate communicating, using the shell script, the first task to the first computing system; and

upon a determination that the number of active tasks is greater than or equal to the first predetermined task limit associated with the first computing system, determine whether the first task is excluded from the first concurrency evaluation;

an interface communicatively coupled to the one or more processors and operable to;

upon a determination that the first task is excluded from the first concurrency evaluation, communicate the first task to the first computing system; and

the one or more processors further operable to;

upon a determination that the first task is not excluded from the first concurrency evaluation, delay, via the shell script, the communication of the first task to the first computing system.

2. The apparatus of claim 1, the processor further operable to:

intercept a second task sent from the task scheduler to the first computing system; and

send the second task to the first computing system in response to a determination that tasks to be performed by the first computing system are to be initiated without checking the number of active tasks being performed by the first computing system.

3. The apparatus of claim 1,

the one or more processors further operable to:

intercept, via the shell, a second task sent from the task scheduler;

select, using the shell script, a second computing system to perform the second task, the second computing system coupled to the apparatus via the network;

determine, using the shell script, whether the second computing system is subject to a second concurrency evaluation;

determine, via the shell script, a number of active tasks initiated by the task scheduler that are being performed by the second computing system;

upon a determination that the second computing system is subject to the second concurrency evaluation, determine, using the shell script, whether the number of active tasks being performed by the second computing system is greater than or equal to a second predetermined task limit;

upon a determination that the number of active tasks being performed by the second computing system is less than the second predetermined task limit associated with the second computing system, facilitate communicating, using the shell script, the second task to the second computing system;

upon a determination that the number of active tasks is greater than or equal to the second predetermined task limit associated with the second computing system, determine whether the second task is excluded from the second concurrency evaluation; and

the interface further operable to;

upon a determination that the second task is excluded from the second concurrency evaluation, communicate the second task to the second computing system; and

the one or more processors further operable to;

upon a determination that the second task is not excluded from the second concurrency evaluation, delay, via the shell script, the communication of the second task to the second computing system.

4. The apparatus of claim 1, wherein the first task is movement of data from the first computing system to a different computing system.

5. The apparatus of claim 1, wherein the one or more processors are further operable to retrieve the first task from a holding queue comprising a plurality of tasks waiting to be performed in response to the determination that the number of active tasks being performed by the first computing system is less than the predetermined task limit associated with the first computing system.

6. A non-transitory computer readable medium comprising logic, the logic, when executed by a processor, operable to:

intercept, via a shell script executed through a command line interface, a first task sent from a task scheduler of a first computing system, the first task specifying one or more actions to be performed and not specifying a computing system for performing the one or more actions;

select, using the shell script, a second computing system to perform the first task, the second computing system coupled to the first computing system via a network;

determine, using the shell script, whether the second computing system is subject to a first concurrency evaluation;

determine, via the shell script, a number of active tasks initiated by the task scheduler that are being performed by the second computing system;

upon a determination that the second computing system is subject to the first concurrency evaluation, determine, using the shell script, whether the number of active tasks being performed by the second computing system is greater than or equal to a first predetermined task limit;

upon a determination that the number of active tasks being performed by the second computing system is less than the first predetermined task limit associated with the second computing system, facilitate communicating, using the shell script, the first task to the second computing system;

upon a determination that the number of active tasks is greater than or equal to the first predetermined task limit associated with the second computing system, determine whether the first task is excluded from the first concurrency evaluation;

upon a determination that the first task is excluded from the first concurrency evaluation, communicate, using an interface, the first task to the second computing system;

upon a determination that the first task is not excluded from the first concurrency evaluation, delay, via the shell script, the communication of the first task to the second computing system.

7. The computer readable medium of claim 6, the logic further operable to:

intercept a second task sent from the task scheduler to the second computing system; and

send the second task to the second computing system in response to a determination that tasks to be performed by the second computing system are to be initiated without checking the number of active tasks being performed by the second computing system.

8. The computer readable medium of claim 6, the logic further operable to:

intercept, via the shell script, a second task sent from a task scheduler of a second computing system, the second task specifying one or more actions to be performed and not specifying a computing system for performing the one or more actions;

select, using the shell script, a third computing system to perform the second task, the third computing system coupled to the second computing system via the network;

determine, using the shell script, whether the third computing system is subject to a second concurrency evaluation;

determine, via the shell script, a number of active tasks initiated by the task scheduler that are being performed by the third computing system;

upon a determination that the third computing system is subject to the second concurrency evaluation, determine, using the shell script, whether the number of active tasks being performed by the third computing system is greater than or equal to a second predetermined task limit;

upon a determination that the number of active tasks being performed by the third computing system is less than the second predetermined task limit associated with the third computing system, facilitate communicating, using the shell script, the second task to the third computing system;

upon a determination that the number of active tasks is greater than or equal to the second predetermined task limit associated with the third computing system, determine whether the second task is excluded from the second concurrency evaluation;

upon a determination that the second task is excluded from the second concurrency evaluation, communicate, using the interface, the second task to the third computing system;

upon a determination that the second task is not excluded from the second concurrency evaluation, delay, via the shell script, the communication of the second task to the third computing system.

9. The computer readable medium of claim 6, wherein the first task is movement of data from the second computing system to a different computing system.

10. The computer readable medium of claim 6, the logic further operable to retrieve the first task from a holding queue comprising a plurality of tasks waiting to be performed in response to the determination that the number of active tasks being performed by the second computing system is less than the predetermined task limit associated with the second computing system.

11. A method comprising:

intercepting, by one or more processors using a shell script executed through a command line interface, a first task sent from a task scheduler of a first computing system, the first task specifying one or more actions to be performed and not specifying a computing system for performing the one or more actions;

selecting, by the one or more processors using the shell script, a second computing system to perform the first task, the second computing system coupled to the first computing system via a network;

determining, by one or more processors using the shell script, whether the second computing system is subject to a first concurrency limitation;

determining, by the one or more processors using the shell script, a number of active tasks initiated by the task scheduler that are being performed by the second computing system;

upon a determination that the second computing system is subject to the first concurrency evaluation, determining, by the one or more processors using the shell script, whether the number of active tasks being performed by the second computing system is greater than or equal to a first predetermined task limit;

upon a determination that the number of active tasks being performed by the second computing system is less than the first predetermined task limit associated with the second computing system, communicating, by an interface via the shell script, the first task to the second computing system;

upon a determination that the number of active tasks is greater than or equal to the first predetermined task limit associated with the second computing system, determining, by the one or more processors using the shell script, whether the first task is excluded from the first concurrency evaluation;

upon a determination that the first task is excluded from the first concurrency evaluation, communicating, using the interface, the first task to the second computing system;

upon a determination that the first task is not excluded from the first concurrency evaluation, delaying, via the shell script, the communication of the first task to the second computing system.

12. The method of claim 11, further comprising:

intercepting, by the one or more processors, a second task sent from the task scheduler to the second computing system; and

sending the second task to the second computing system in response to a determination that tasks to be performed by the second computing system are to be initiated without checking the number of active tasks being performed by the second computing system.

13. The method of claim 11, further comprising:

intercepting, by one or more processors using the shell script, a second task sent from a task scheduler of a second computing system, the second task specifying one or more actions to be performed and not specifying a computing system for performing the one or more actions;

selecting, by the one or more processors using the shell script, a third computing system to perform the second task, the third computing system coupled to the second computing system via the network;

determining, by the one or more processors using the shell script, whether the third computing system is subject to a second concurrency limitation;

determining, by the one or more processors using the shell script, a number of active tasks initiated by the task scheduler that are being performed by the third computing system;

upon a determination that the third computing system is subject to the second concurrency evaluation, determining, by the one or more processors using the shell script, whether the number of active tasks being performed by the third computing system is greater than or equal to a second predetermined task limit;

upon a determination that the number of active tasks being performed by the third computing system is less than the second predetermined task limit associated with the third computing system, communicating by an interface via the shell script, the second task to the third computing system;

upon a determination that the number of active tasks is greater than or equal to the second predetermined task limit associated with the third computing system, determining, by the one or more processors using the shell script, whether the second task is excluded from the second concurrency evaluation;

upon a determination that the second task is excluded from the second concurrency evaluation, communicating, by an interface, the second task to the third computing system;

upon a determination that the second task is not excluded from the second concurrency evaluation, delaying, via the shell script, the communication of the second task to the third computing system.

14. The method of claim 11, wherein the first task is movement of data from the second computing system to a different computing system.

15. The method of claim 11, further comprising retrieving the first task from a holding queue comprising a plurality of tasks waiting to be performed in response to the determination that the number of active tasks being performed by the second computing system is less than the predetermined task limit associated with the second computing system.