I’ve been using Windows Workflow Foundation for a small personal project to learn more about it and see what it can do. It’s pretty powerful and I’m looking forward to delving more into it. For my purposes though, I’m hosting the workflow in a console program.
If you look around the internet, you’ll see lots of examples of hosting a sequential workflow in a synchronous manner, even though the WorkflowRuntime only support asynchronous operations. That code usually looks like this (example adapted from wf-training-guide.com to add support for input/output arguments):
static void Main(string[] args)
{
Dictionary<string, object> inputArguments = new Dictionary<string, object>();
inputArguments.Add("Argument1", args[0]);
Dictionary<string, object> outputArguments;
// Create the WF runtime.
using(WorkflowRuntime workflowRuntime = new WorkflowRuntime())
{
// Hook into WorkflowCompleted / WorkflowTerminated events.
AutoResetEvent waitHandle = new AutoResetEvent(false);
workflowRuntime.WorkflowCompleted
+= delegate(object sender, WorkflowCompletedEventArgs e)
{
outputArguments = e.OutputParameters;
waitHandle.Set();
};
workflowRuntime.WorkflowTerminated
+= delegate(object sender, WorkflowTerminatedEventArgs e)
{
Console.WriteLine(e.Exception.Message);
waitHandle.Set();
};
// Create an instance of the WF to execute and call Start().
WorkflowInstance instance =
workflowRuntime.CreateWorkflow(typeof(WorkflowClass));
instance.Start();
waitHandle.WaitOne();
}
}
Unfortunately, that’s a ton of code to do only a few things:
- Take input arguments
- Instantiate a WorkflowRuntime
- Create a workflow instance
- Run the workflow
- Handle any exceptions (poorly)
- Return output parameters from the workflow
- Do all of this in a synchronous manner.
What if we could just call a method similar to this:
var outputArguments = RunWorkflow<WorkflowClass>(arguments, completedEvent, terminatedEvent);
Well, now you can! I’ve written this wrapper class to allow exactly that:
public class WorkflowManager
{
public static Dictionary<string, object> RunWorkflow<T>(
Dictionary<string, object> arguments,
EventHandler<WorkflowCompletedEventArgs> completedEvent,
EventHandler<WorkflowTerminatedEventArgs> terminatedEvent)
where T : SequentialWorkflowActivity
{
using (WorkflowRuntime runtime = new WorkflowRuntime())
{
Dictionary<string, object> returnValue = null;
Exception ex = null;
using (AutoResetEvent waitHandle = new AutoResetEvent(false))
{
WorkflowInstance instance = runtime.CreateWorkflow(typeof(T), arguments);
runtime.WorkflowCompleted += (o, e) =>
{
EventHandler<WorkflowCompletedEventArgs> temp = completedEvent;
if (temp != null)
{
temp(o, e);
}
returnValue = e.OutputParameters;
waitHandle.Set();
};
runtime.WorkflowTerminated += (o, e) =>
{
EventHandler<WorkflowTerminatedEventArgs> temp = terminatedEvent;
if (temp != null)
{
temp(o, e);
}
ex = e.Exception;
waitHandle.Set();
};
instance.Start();
waitHandle.WaitOne();
}
if (runtime != null)
{
runtime.StopRuntime();
}
if (ex != null)
{
throw ex;
}
return returnValue;
}
}
}
Now you really can run the above code to execute your workflow in a synchronous manner without all kinds of messy code. Beware creating multiple WorkflowRuntime instances though. If you are managing multiple simultaneous workflows, you’ll need to pass in instance IDs and keep track in the runtime of which one is completing or throwing errors. It’s generally a bad idea to have multiple WorkflowRuntimes.
Enjoy now being able to write:
var outputArguments = RunWorkflow<WorkflowClass>(arguments, completedEvent, terminatedEvent);
Recent Comments