Composable and cancelable dataflow continuation passing

A method, comprising:

• creating a plurality of parallel tasks including a first task and a second task in a data flow at runtime, wherein each task resolves a future;
• supplying at least one of three possible continuations for each of the tasks including a success continuation, a cancellation continuation, and a failure continuation;
• returning a value as the future of the first task upon a success continuation for the first task;
• and
• applying the value in the second task to compute a second future;
• wherein the cancellation continuation is supplied if the first task is cancelled and the failure continuation is supplied with an exception if the first task does not return a value and the first task is not cancelled.

A system, comprising:

• memory to store a set of instructions;
• and
• a processor to execute the set of instructions to:
• create a plurality of parallel tasks including a first task and a second task in a data flow at runtime, wherein each task resolves a future;
• supply at least one of three possible continuations for each of the tasks including a success continuation, a cancellation continuation, and a failure continuation;
• return a value as the future of the first task upon a success continuation for the first task;
• and
• apply the value in the second task to compute a second future;
• wherein the cancellation continuation is supplied if the first task is cancelled and the failure continuation is supplied with an exception if the first task does not return a value and the first task is not cancelled.