活动-工作流实例扩展一对一关系

Question

我正在尝试实现一个 WF4 活动扩展，它可以处理一些长时间运行的数据处理，并时不时地将信息发送回“母亲”活动。

我实现了这个版本，但如果我在并行活动上下文中使用此活动，我会遇到问题。从下面的代码可以看出，该活动正在创建书签，然后调用 MyActivityExtension 对象。 我希望 MyActivity 类的每个实例都有一个不同的 MyActivityExtension 实例进行通信。如果在一个工作流定义中顺序使用这种类型的两个活动，则一切正常，并且对扩展类的调用是对不同的对象进行的，但如果一个活动开始执行，而另一个活动空闲，则第二个活动使用相同的扩展实例，例如闲置的那个。

下面我添加了代码的简化示例。知道如何在活动实例和活动扩展实例之间强加一对一的关系吗？

先感谢您， Alex

MyActivity 代码：

    protected override void Execute(NativeActivityContext context)
    {
        //Some data processing....

        //Obtain the activity extension
        MyActivityExtension extension = context.GetExtension<MyActivityExtension >();


        string bookmarkName = "MyActivity_" + Guid.NewGuid().ToString();
        var bookmark = context.CreateBookmark(bookmarkName, BookmarkResumed);

        extension.ProcessData(bookmarkName);
    }

    protected override void CacheMetadata(NativeActivityMetadata metadata)
    {
        base.CacheMetadata(metadata);
        metadata.AddDefaultExtensionProvider<MyActivityExtension >(() => new MyActivityExtension ());
    }

 private void BookmarkResumed(NativeActivityContext context, Bookmark bookmark, object value)
    {
       //some data retrieving operations
    }

MyActivityExtension 代码：

public class MyActivityExtension : IWorkflowInstanceExtension
{
    private WorkflowInstanceProxy instance;
    private Guid id;

    public MyActivityExtension()
    {
         id = Guid.NewGuid();
    }

    internal void ProcessData(string bookmarkName)
    {
        Console.WriteLine("My activity extension Id: " + id.ToString());

        //Some data processing
    }

    public IEnumerable<object> GetAdditionalExtensions()
    {
        return null;
    }

    public void SetInstance(WorkflowInstanceProxy instance)
    {
        this.instance = instance;
    }
}

Answer 1

IWorkflowInstanceExtension 有助于实现一种工作流关系的一对一扩展，但正如您发现的那样，每个活动都将共享相同的扩展。没有现成的方法可以为每个活动创建新的扩展。我要做的是将扩展更改为某种扩展工厂，并使用返回新对象的 Create() 函数。

所以你的代码看起来像这样：

   protected override void Execute(NativeActivityContext context)
    {
        //Some data processing....

        //Obtain the activity extension
        MyActivityExtensionFactory extensionFactory = context.GetExtension<MyActivityExtensionFactory >();
        MyActivityExtension extension = extensionFactory.Create();

        string bookmarkName = "MyActivity_" + Guid.NewGuid().ToString();
        var bookmark = context.CreateBookmark(bookmarkName, BookmarkResumed);

        extension.ProcessData(bookmarkName);
    }