zoukankan      html  css  js  c++  java
  • WF4 Beta2 工作原理

    最顶层的Activity类提供了一个可以供子类重写的InternalExecute()方法:

    internal virtual void InternalExecute(ActivityInstance instance, ActivityExecutor executor, BookmarkManager bookmarkManager);

             子类可以重写此方法,在此方法中实现各种功能,这个方法在WF4内部非常重要,许多东西都与它相关。

             为了方便地供开发者自定义业务处理逻辑,诸如CodeActivity之类最底层的类,另定义了一个抽象的Execute()方法:

    protected abstract void Execute(CodeActivityContext context);

             当开发者自定义Activity时,就可以直接地重写此方法。

             简言之,工作流的运行就体现为Activity对象树中叶子节点Execute方法(或类似的方法,比如DynamicActivityInternalExecute方法,AsyncCodeActivityBeginExecuteEndExecute方法)的执行

    WF4中工作流的执行原理

    首先要明确,在WF4中,如果使用WorkflowInvoker类来启动工作流时:

    WorkflowInvoker.Invoke(new Workflow1());

             工作流Workflow1将在调用者的线程中执行。这种情况下,工作流的执行类似于方法调用,是最简单的执行模式。

             然而,如果使用WorkflowApplication启动工作流,工作流实例将在调用者线程之外的另一个线程中运行:

             WorkflowApplication wpp = new WorkflowApplication(new Workflow1());

             wpp.Run();

             而且,这个“另外的工作线程”是线程池中的线程

             不管是由哪个线程负责执行工作流,有一个原则是很重要的:

             单个工作流实例是单线程执行的,哪怕诸如Parallel Activity给你一个多分支“并行”运行的假象。

             事实上,Parallel Activity采用在单线程中“轮换执行”各分支。当一个分支进入空闲“Idle”时,工作流调度器调度下一分支投入运行。所果所有分支都不包括使本分支进入Idle状态的Activtity(比如有一个Delay              Activity或创建了书签),则Parallel Activity按从左到右的顺序执行各分支。

             那么,构成工作流的各个Activity实例是如何执行的?

             WF运行时在内部为每个工作流维护了一个工作项队列。然后,创建一个Scheduler类的实例来负责从此工作项队列中取出和追加工作项,并执行之。

             这里要说说这个工作项队列,在Scheduler类的代码中可以找到它的声明:

             private Quack<WorkItem> workItemQueue;

             这里有一个奇怪的Quack<T>泛型类,我仔细看了一下,其实它就是一个泛型队列,但它有一点特殊之处:

             Quack<T>泛型类在内部使用一个数组来保存数据:

             private T[] items;

             初始时,为队列分配可容纳4T类型对象的内存空间,当不断增加对象而需要扩充空间时,就分配一个“当前所占内存空间*2”的新数组,再将老数组中的内容复制到新数组中。

             很明显,在两个数组中复制元素会花费系统资源,我不知道为何WF4的设计者这样设计,估计是他们有其他的考虑。

             队列中的WorkItem对象很有趣,它代表一个将被执行的Activity实例,这里暂时放下,一会儿还会介绍它。

             Scheduler对象的工作可以简述如下:

             它从队列中取出一个WorkItem对象,然后将其委托给线程池中的线程(如果工作流由WorkApplication以异步方式启动执行)或调用者线程(如果工作流由WorkflowInvoker以同步方式启动执行)执行。这些线程       将负责调用WorkItem所封装的Activity实例的Execute()方法(或类似的方法,如前所述)。 

     深入分析Activity执行的流程

             一个Activity实例到底是如何执行的?一切得从WorkItem类开始。

             WorkItem是一个抽象基类,提供了几个抽象方法其中最重要的就是Execute()方法:

    internal abstract class WorkItem

    {

        //……

        private ActivityInstance activityInstance;

        public abstract bool Execute(ActivityExecutor executor,

            BookmarkManager bookmarkManager);

    }

             上述声明中还有两个很重要的类ActivityInstanceActivityExecutor

             ActivityInstance代表着正在运行的一个Activity实例包容一堆的internal方法可以完成Activity的执行(Execute)取消(Cancel)和放弃(Abort)的功能。 ActivityExecutor则负责调用ActivityInstance中的这些       方法。

             WorkItem有一堆的子类,这些子类又派生出“孙”类。比如,其中的一个分支如下:

           

    不管有几个子孙,后代一般都重写了WorkItem所定义的Execute()抽象方法。

             我们以ExecuteRootWorkItem类为例,顾名思义,这应该是与工作流中最顶层的Activity相对应的WorkItem。它的Execute()方法如下所示:

    public override bool Execute(ActivityExecutor executor, BookmarkManager bookmarkManager)

    {

        return base.ExecuteBody(executor, bookmarkManager, this.resultLocation);

    }

             它将调用基类ExecuteActivityWorkItemExecuteBody()方法,此方法的关键代码如下:

    protected bool ExecuteBody(ActivityExecutor executor, BookmarkManager bookmarkManager, Location resultLocation)

    {

          //……

          base.ActivityInstance.Execute(executor, bookmarkManager);

          //……

    }

             可以看到,它直接跳去执行最顶层基类WorkItem所定义的ActivityInstance对象的Execute()方法。此方法的代码如下:

    internal void Execute(ActivityExecutor executor, BookmarkManager bookmarkManager)

    {

        //……

        this.Activity.InternalExecute(this, executor, bookmarkManager);

    }

             注意ActivityInstance实际上封装了一个Activity对象:

    public sealed class ActivityInstance : ActivityInstanceMap.IActivityReference

    {

          public Activity Activity { get; internal set; }

          //……

             所以,ActivityInstance对象的Execute()方法实际上执行的是Activity对象的InternalExecute()方法。再追踪下去: 

    internal virtual void InternalExecute(ActivityInstance instance, ActivityExecutor executor, BookmarkManager bookmarkManager)

    {

         //……

         executor.ScheduleActivity(this.runtimeImplementation, instance, null, null, null);

    }

       注意:上述代码是Acitivity对InternalExecute()默认的实现方式,它的子类(比如CodeActivity)通常会重写它。

           可以看到,在ActivityInstance对象的Execute()方法中,执行流程转给了从前面一路传送过来的ActivityExecutor对象,由此对象的ScheduleActivity方法负责将Activity插入到工作项队列中。

           ActivityExecutor.ScheduleActivity方法又进行了一个“倒手”,调用自己的ScheduleBody()方法: 

    private ActivityInstance ScheduleActivity(……)

    {

         //……

         this.ScheduleBody(scheduledInstance, requiresSymbolResolution, argumentValueOverrides, resultLocation);

    }

    ScheduleBody()方法中,“佛祖”终于现出真身,我们看到了Scheduler的身影:

    internal void ScheduleBody(ActivityInstance activityInstance, bool requiresSymbolResolution, IDictionary<string, object> argumentValueOverrides, Location resultLocation)

    {

        if (resultLocation == null)

        {

             //……

             this.scheduler.PushWork(new ExecuteExpressionWorkItem(activityInstance, requiresSymbolResolution, argumentValueOverrides, resultLocation));

             //……

    }

          在上述代码中,Scheduler对象将activityInstance转换为了一个ExecuteExpressionWorkItem,然后将其插入到工作项队列中等待执行。

      现在我们看到,默认情况下,对ExecuteRootWorkItem的执行将导致一个新的ExecuteExpressionWorkItem工作项被插入到工作项队列中。

    工作项队列中的工作项是如何调度执行的?

         Scheduler类负责工作项的调度执行。       

         Scheduler类的构造函数中,挂接了一个回调函数OnScheduledWork

    static Scheduler()

    {

        //……

        onScheduledWorkCallback = Fx.ThunkCallback(new SendOrPostCallback(Scheduler.OnScheduledWork));

    }

          OnScheduledWork()函数中,揭露出了任务项调度是如何进行的秘密:

    private static void OnScheduledWork(object state)

    {

            //取出队列中的第一个工作项

            WorkItem firstWorkItem = scheduler.firstWorkItem;

            if ((scheduler.workItemQueue != null) && (scheduler.workItemQueue.Count > 0))

            {

                scheduler.firstWorkItem = scheduler.workItemQueue.Dequeue();

            }

            else

            {

                scheduler.firstWorkItem = null;

            }

            //执行这一工作项

            continueAction = scheduler.callbacks.ExecuteWorkItem(firstWorkItem);

            //……

    }

             下面是ExecuteWorkItem()方法的代码,可以看到,最后调度器还是委托activityExecutor来执行Activity的:

    public Scheduler.RequestedAction ExecuteWorkItem(WorkItem workItem)

    {

        Scheduler.RequestedAction objA = this.activityExecutor.OnExecuteWorkItem(workItem);

        //……

    }

    ActivityExecutorOnExecuteWorkItem()方法有很多代码,其中关键的就是以下这几句:

    internal Scheduler.RequestedAction OnExecuteWorkItem(WorkItem workItem)

    {

          //……

          propertyManagerOwner.PropertyManager.SetupWorkflowThread();

          if ((abortException == null) && !workItem.Execute(this, this.bookmarkManager))

          {

                 return Scheduler.YieldSilently;

          }

           //……

    }

             我们终于发现了调用工作项的Execute()方法的语句

             有的朋友可能会疑惑,我们的探索之旅从WorkItem.Execute()方法开始,转了一圈怎么又回到了WorkItem.Execute()方法?这样一来,调用工作项的WorkItem.Execute()方法将导致一个工作项被加入到队列中,然后当此工作项被执行时,它又将一个工作项加入到队列中,这会不会引发无限递归?

             事实上这正是我们想要的效果。因为一个工作流实例实际上就是一个层层嵌套的递归的结构,这种设计使得执行其顶层Activity对象的Execute()方法时,会将其子Activity所对应的WorkItem加入到队列中加以递归执行。

             很明显,对于那些不包容子ActivityActivity,我们应该“打断”这种递归执行的过程。WF4是怎么做到的?

          以一个实例来说明更好。 请看以下自定义的Activity:

    public sealed class Prompt : CodeActivity

    {

            public InArgument<string> Text { get; set; }

             protected override void Execute(CodeActivityContext context)

            {

                    Console.Write(Text.Get(context));

            }

    }

             注意上述Activity重写了基类CodeActivityExecute()方法,此方法一执行完毕就会返回。

             前面说过,对工作项队列中WorkItem.Execute()方法的调用,最终将转换为对ActivityInstance对象的Execute()方法的调用。而ActivityInstance又包容了最终的Activity对象实例,并将调用转给这一最终对象的InternalExecute()方法,为方便起见,重贴此方法代码如下:

    internal void Execute(ActivityExecutor executor, BookmarkManager bookmarkManager)

    {

        //……

        this.Activity.InternalExecute(this, executor, bookmarkManager);

    }

             在我们的自定义Activity中,没有重写CodeActivityInternalExecute()方法(事实上也不可能,因为此方法是Sealed),所以,被调用的实际上是基类CodeActivityInternalExecute()方法。以下是CodeActivityInternalExecute()方法代码:

    internal sealed override void InternalExecute(ActivityInstance instance, ActivityExecutor executor, BookmarkManager bookmarkManager)

    {

        //……

        this.Execute(context);

        //……

    }

             非常清楚,它应用了多态特性,调用子类重写的Execute()方法,注意,它并没有调用最顶层Activity类所提供的InternalExecute()方法。

             所以,问题的关键在于最顶层基类ActivityInternalExecute()方法,默认情况下,此方法将会通过 ActivityExecutor.ScheduleActivity()方法的调用将一个工作项加入到队列中,但CodeActivity没调用Activity基类的InternalExecute()方法而是重写了此方法,所以就打断了“递归”调用链。

    小结

    不知道朋友们是不是有点昏了,没办法,WF4内部就是有这么多的弯弯绕。         

    简单地说:

      工作流执行时,所有需要被执行的Activity会被封装为一个WorkItem,被放到一个工作项队列中,然后由WF4调度器(其实就是Scheduler类的实例)负责从此队列中取出工作项执行。

        工作项的执行可以由线程池中的线程承担。,也可以由调用者线程来承担。

         WF4内部的工作原理非常复杂,事实上我们也没有必要了解其每个技术细节。但如果能了解其大致的内部原理还是非常有用的,它能帮助我们避开陷阱,真正地把技术用好。

           对于技术,不仅要知其然,还要知其所以然。才能真正拥有了自由。 

    转载自:http://www.cnblogs.com/bitfan/archive/2009/10/29/1592591.html 
     

  • 相关阅读:
    redhat yum替换成CentOS yum 并修改源
    C++11新特性实验
    常见的安装包制作程序installer
    如何在数据库中删除并添加唯一索引?
    springboot中的restTemplate工具类
    如何使用swagger(一)
    The POM for com.qingmu:entity:jar:1.0.0-SNAPSHOT is missing, no dependency information available
    java.lang.IllegalStateException: Found multiple @SpringBootConfiguration annotated classes
    在使用postman中配置返回html页面
    Springboot中设置返回数据的时间格式
  • 原文地址:https://www.cnblogs.com/malaikuangren/p/2551467.html
Copyright © 2011-2022 走看看