首页 > 其他 > 详细

Workflow笔记二

时间:2016-12-18 10:07:34      阅读:216      评论:0      收藏:0      [点我收藏+]

状态机工作流

    在上一节Workflow笔记1——工作流介绍中,介绍的是流程图工作流,后来微软又推出了状态机工作流,它比流程图功能更加强大。

    新建项目StatueWorkflowConsoleApp

技术分享

技术分享

    自动添加了一个起始节点和一个状态节点.

 技术分享

技术分享技术分享

 

技术分享

    运行结果如下:

技术分享

    注意执行顺序。接下来,扩展此工作流。

    1、设置全局变量Num

技术分享

    2、双击T1,为变量Num赋值

 技术分享

new Random().Next(0,10)

    运行结果如下:

技术分享

启动工作流

    之前我们新建的工作流项目,都是通过如下方式来启动工作流的。

            Activity workflow1 = new Workflow1();
            WorkflowInvoker.Invoke(workflow1);

    而在工作中,我们通常不能通过这样的方式来启动工作流。因为我们的流程启动后,我需要监控流程的各种状态。而我们通过Invoke的方式启动工作流,是无法监控工作流的状态的。

    我们可以通过WorkflowApplication类启动工作流。参考:https://msdn.microsoft.com/zh-cn/library/system.activities.workflowapplication(v=vs.110).aspx

    1、新建Windows窗体应用程序,WindowsWorkFlowApp

技术分享

    2、右键单击项目WindowsWorkFlowApp,新建活动,添加状态机

技术分享

    3、双击State1,添加输入参数

技术分享

    4、再添加一个状态和结束状态

技术分享

    5、双击FinalState,在其中添加输出

技术分享

    修改State2

技术分享

    6、修改“启动工作流”按钮的事件代码如下:

        private void btnStartWorkFlow_Click(object sender, EventArgs e)
        {
            WorkflowApplication app = new WorkflowApplication(new Activity1(), new Dictionary<string, object>() { 
            {"InputName","神刀张三"}
            });
            app.Run();
        }

    我们来看下WorkflowApplication的构造函数。

构造函数

名称

说明

WorkflowApplication(Activity)

使用指定的工作流定义创建 WorkflowApplication 类的新实例。

WorkflowApplication(Activity, IDictionary<String, Object>)

创建 WorkflowApplication 类的新实例,该实例使用指定的工作流定义和参数值。

WorkflowApplication(Activity, IDictionary<String, Object>, WorkflowIdentity)

创建的新实例 WorkflowApplication 类,该类使用指定的工作流定义和参数值和定义标识。

WorkflowApplication(Activity, WorkflowIdentity)

创建的新实例 WorkflowApplication 使用指定的工作流定义和定义标识的类。

    7、由于我创建的是Windows应用程序,那么要想输出控制台信息,我们必须修改项目的输出方式

技术分享

    8、运行项目

技术分享

WorkflowApplication生命周期

    那么我们如何来监控工作流的状态呢,我们可以使用指定的工作流定义构造 WorkflowApplication,处理所需的工作流生命周期事件,并通过调用 Run 来调用工作流。

在Run方法调用之前,我们来注册生命周期事件,添加代码如下:

 #region 工作流生命周期事件
            app.Unloaded = delegate(WorkflowApplicationEventArgs er)
              {
                  Console.WriteLine("工作流 {0} 卸载.", er.InstanceId);
              };
            app.Completed = delegate(WorkflowApplicationCompletedEventArgs er)
            {
                Console.WriteLine("工作流 {0} 完成.", er.InstanceId);
            };
            app.Aborted = delegate(WorkflowApplicationAbortedEventArgs er)
            {
                Console.WriteLine("工作流 {0} 终止.", er.InstanceId);
            };
            app.Idle = delegate(WorkflowApplicationIdleEventArgs er)
            {
                Console.WriteLine("工作流 {0} 空闲.", er.InstanceId);
            };
            app.PersistableIdle = delegate(WorkflowApplicationIdleEventArgs er)
            {
                Console.WriteLine("持久化");
                return PersistableIdleAction.Unload;
            };
            app.OnUnhandledException = delegate(WorkflowApplicationUnhandledExceptionEventArgs er)
            {
                Console.WriteLine("OnUnhandledException in Workflow {0}\n{1}",
       er.InstanceId, er.UnhandledException.Message);
                return UnhandledExceptionAction.Terminate;
            }; 
            #endregion

    再次运行项目,结果如下:

技术分享

多线程信号量机制

    Run方法会开启一个新的线程。而通常,我们需要等待工作流运行完成之后再回到主线程。那么我们可以使用AutoResetEvent一个线程通过调用等待一个信号 WaitOneAutoResetEvent

在工作流实例化之前,就创建一个AutoResetEvent对象。

AutoResetEvent syncEvent = new AutoResetEvent(false);

    然后在工作流的Completed事件中,执行Set方法,将事件状态设置为有信号,从而允许一个或多个等待线程继续执行,说白了就是一个唤醒操作。

syncEvent.Set();

    最后在Run方法的后面,添加

syncEvent.WaitOne();

    WaitOne方法将阻止当前线程,直到当前 WaitHandle 收到信号,从而实现等待工作流线程运行完成的功能。

    源码下载:WorkflowConsoleApp2.zip

Workflow笔记二

原文:http://www.cnblogs.com/jiekzou/p/6192813.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!