Dependency-aware server processing of dataflow applications

A computing system comprising:

• a plurality of dependency-aware (DA) queues;
• a DA server comprising one or more reconfigurable processors;
• and
• a plurality of work requests enqueued among the plurality of DA queues, wherein:
• the plurality of DA queues are configured for execution on the one or more reconfigurable processors,
• the plurality of work requests comprise functions of an application to execute by the DA server, and
• the DA server is configured to:
• receive a first work request from a first DA queue among the plurality of work requests enqueued among the plurality of DA queues, wherein:
• the plurality of work requests comprise functions of an application to be executed by the one or more reconfigurable processors,
• the first DA queue is associated with a processing dependency associated with processing the first work request,
• processing a second work request is dependent upon a processing condition included in the processing dependency, and
• the second work request is enqueued in a second DA queue among the plurality of DA queues;
• responsive to the processing condition has not been being met:
• defer processing of the second work request on the one or more reconfigurable processors;
• while deferring processing of the second work request, receive a third work request enqueued in the second DA queue;
• and
• responsive to determining that processing the third work request not being dependent upon the processing condition, process the third work request, wherein processing the third request causes the processing condition to be met;
• and
• responsive to the processing condition being met:
• processing the second work request;
• setting a value representing null data of a record of the processing condition;
• and
• performing a conditioned action associated with the processing condition and a concurrency primitive, wherein:
• the processing condition comprises a first DA queue identifier of the first DA queue,
• the first DA queue identifier comprises an ordinal number and a memory address of the first DA queue, and
• a second DA queue identifier of the second DA queue is based on the first DA queue identifier and a multiple of a stride.

A computer program product comprising a computer readable storage medium having program instructions embodied therewith, wherein the program instructions are executable by at least one processor of a computing system to cause the at least one processor to:

• receive a first work request from a first DA queue among a plurality of work requests enqueued among a plurality of DA queues, wherein:
• the plurality of work requests comprise functions of an application to be processed by the at least one processor,
• the first DA queue is associated with a processing dependency associated with processing the first work request,
• processing a second work request is dependent upon a processing condition included in the processing dependency, and
• the second work request is enqueued in a second DA queue among the plurality of DA queues;
• based on the processing condition not being met:
• defer processing, by the at least one processor, of the second work request;
• while deferring processing of the second work request, receive a third work request enqueued in the second DA queue;
• and
• responsive to the third work request not being dependent upon the processing condition, process by the at least one processor, the third work request, wherein processing the third request causes the processing condition to be met;
• and
• responsive to the processing condition being met:
• process the second work request;
• set a value representing null data of a record of the processing condition;
• and
• perform a conditioned action associated with the processing condition and a concurrency primitive, wherein:
• the processing condition comprises a first DA queue identifier of the first DA queue,
• the first DA queue identifier comprises an ordinal number and a memory address of the first DA queue, and
• a second DA queue identifier of the second DA queue is based on the first DA queue identifier and a multiple of a stride.