学步园

说明

例子下载:

http://files.cnblogs.com/wxwinter/aec10_1.rar

http://files.cnblogs.com/wxwinter/aec10_2.rar

 

取消的实现

取消处理器CancellationHandlerActivity的使用

 

 

例子:取消

内容控件Activity

public
class
内容控件: Activity

    {

protected
override
ActivityExecutionStatus Execute(ActivityExecutionContext executionContext)

{

this.Invoke(正常业务, new
EventArgs());

return
ActivityExecutionStatus.Executing;

}

 

protected
override
ActivityExecutionStatus Cancel(ActivityExecutionContext executionContext)

{

System.Console.WriteLine("取消");

this.Invoke(取消业务, new
EventArgs());

return
ActivityExecutionStatus.Canceling;

// return ActivityExecutionStatus.Closed;

}

 

void 正常业务(object sender, EventArgs e)

{

System.Console.WriteLine("wxwinter");

ActivityExecutionContext aec = sender as
ActivityExecutionContext;

aec.CloseActivity();

}

 

void 取消业务(object sender, EventArgs e)

{

//用于处理取消是否恢复的业务

ActivityExecutionContext aec = sender as
ActivityExecutionContext;

aec.CloseActivity();

}

    }

 

容器控件Activity

public
class
容器控件: SequenceActivity

    {

        public 容器控件()

        {

            InitializeComponent();

        }

 

[System.Diagnostics.DebuggerNonUserCode]

private
void InitializeComponent()

{

this.CanModifyActivities = true;

this.内容控件1 = new wxwinterAecTest.内容控件();

this.内容控件1.Name = "内容控件1";

this.Activities.Add(this.内容控件1);

this.CanModifyActivities = false;

}

 

private
内容控件 内容控件1;

 

protected
override
ActivityExecutionStatus Execute(ActivityExecutionContext executionContext)

{

this.内容控件1.Closed += activity11_Closed;

this.内容控件1.Executing+=new
EventHandler<ActivityExecutionStatusChangedEventArgs>(activity11_Executing);

executionContext.ExecuteActivity(this.内容控件1);

return
ActivityExecutionStatus.Executing;

 

}

 

bool IsCancel = false;

 

void activity11_Executing(object sender, ActivityExecutionStatusChangedEventArgs e)

{

IsCancel = true; //一个模拟要取消的业务情形

if (IsCancel)

{

ActivityExecutionContext aec = sender as
ActivityExecutionContext;

aec.CancelActivity(this.内容控件1);

}

}

 

void activity11_Closed(object sender, ActivityExecutionStatusChangedEventArgs e)

{

e.Activity.Closed -= activity11_Closed;

ActivityExecutionContext aec = sender as
ActivityExecutionContext;

aec.CloseActivity();

}

    }

 

测试用工作流

public
class
Workflow1: SequentialWorkflowActivity

{

private
容器控件 容器控件1;

        public Workflow1()

        {

            InitializeComponent();

        }

 

[System.Diagnostics.DebuggerNonUserCode]

private
void InitializeComponent()

{

this.CanModifyActivities = true;

this.容器控件1 = new wxwinterAecTest.容器控件();

//

// 容器控件1

//

this.容器控件1.Name = "容器控件1";

//

// Workflow1

//

this.Activities.Add(this.容器控件1);

this.Name = "Workflow1";

this.CanModifyActivities = false;

}

    }

 

宿主

class
Program

{

static
void Main()

{

WorkflowRuntime workflowRuntime = new
WorkflowRuntime();

workflowRuntime.WorkflowCompleted +=new
EventHandler<WorkflowCompletedEventArgs>(workflowRuntime_WorkflowCompleted);

workflowRuntime.WorkflowTerminated +=new
EventHandler<WorkflowTerminatedEventArgs>(workflowRuntime_WorkflowTerminated);

workflowRuntime.WorkflowIdled+=new
EventHandler<WorkflowEventArgs>(workflowRuntime_WorkflowIdled);

WorkflowInstance instance = workflowRuntime.CreateWorkflow(typeof(Workflow1));

instance.Start();

 

System.Console.Read();

 

}

 

static
void workflowRuntime_WorkflowIdled(object sender, WorkflowEventArgs e)

{

System.Console.WriteLine("WorkflowIdled");

}

 

static
void workflowRuntime_WorkflowTerminated(object sender, WorkflowTerminatedEventArgs e)

{

System.Console.WriteLine("Terminated" + e.Exception.Message);

}

 

static
void workflowRuntime_WorkflowCompleted(object sender, WorkflowCompletedEventArgs e)

{

System.Console.WriteLine("WorkflowCompleted");

}

 

}

 

运行结果

IsCancel = true;

IsCancel = false

 

例子:取消处理器CancellationHandlerActivity

支持取消的控件Activity

public
class
支持取消的控件 : SequenceActivity

{

protected
override
ActivityExecutionStatus Execute(ActivityExecutionContext executionContext)

{

this.EnabledActivities[0].Closed +=Activity_Closed;

executionContext.ExecuteActivity(this.EnabledActivities[0]);

return
ActivityExecutionStatus.Executing;

}

 

void Activity_Closed(object sender, ActivityExecutionStatusChangedEventArgs e)

{

ActivityExecutionContext aec = sender as
ActivityExecutionContext;

aec.CloseActivity();

}

 

protected
override
ActivityExecutionStatus Cancel(ActivityExecutionContext executionContext)

{

foreach (var v in
this.Activities)

{

if (v is
CancellationHandlerActivity)

{

v.Closed += CancellationHandlerActivity_Closed;

executionContext.ExecuteActivity(v);

return
ActivityExecutionStatus.Canceling;

}

}

return
ActivityExecutionStatus.Closed;

}

 

void CancellationHandlerActivity_Closed(object sender, ActivityExecutionStatusChangedEventArgs e)

{

ActivityExecutionContext aec = sender as
ActivityExecutionContext;

aec.CloseActivity();

}

 

}

 

可取消的容器Activity

public
class
可取消的容器 : SequenceActivity

{

protected
override
ActivityExecutionStatus Execute(ActivityExecutionContext executionContext)

{

this.EnabledActivities[0].Closed += activity_Closed;

this.EnabledActivities[0].Executing += activity_Executing;

executionContext.ExecuteActivity(this.EnabledActivities[0]);

return
ActivityExecutionStatus.Executing;

}

public
bool 是否取消 { get; set; }

void activity_Executing(object sender, ActivityExecutionStatusChangedEventArgs e)

{

if (是否取消)

{

ActivityExecutionContext aec = sender as
ActivityExecutionContext;

aec.CancelActivity(this.EnabledActivities[0]);

}

}

 

void activity_Closed(object sender, ActivityExecutionStatusChangedEventArgs e)

{

e.Activity.Closed -= activity_Closed;

ActivityExecutionContext aec = sender as
ActivityExecutionContext;

aec.CloseActivity();

}

}

 

测试用工作流

 

 

 

 

public
class
Workflow1: SequentialWorkflowActivity

{

private
CodeActivity 正常路径业;

private
支持取消的控件 支持取消的控件1;

private
CodeActivity 取消业务路径;

private
CancellationHandlerActivity cancellationHandlerActivity1;

private
可取消的容器 可取消的容器1;

 

        public Workflow1()

        {

            InitializeComponent();

        }

[System.Diagnostics.DebuggerNonUserCode]

private
void InitializeComponent()

{

this.CanModifyActivities = true;

this.取消业务路径 = new System.Workflow.Activities.CodeActivity();

this.cancellationHandlerActivity1 = new System.Workflow.ComponentModel.CancellationHandlerActivity();

this.正常路径业 = new System.Workflow.Activities.CodeActivity();

this.支持取消的控件1 = new wxwinterAecTest.支持取消的控件();

this.可取消的容器1 = new wxwinterAecTest.可取消的容器();

//

// 取消业务路径

//

this.取消业务路径.Name = "取消业务路径";

this.取消业务路径.ExecuteCode += new System.EventHandler(this.取消业务路径_ExecuteCode);

//

// cancellationHandlerActivity1

//

this.cancellationHandlerActivity1.Activities.Add(this.取消业务路径);

this.cancellationHandlerActivity1.Name = "cancellationHandlerActivity1";

//

// 正常路径业

//

this.正常路径业.Name = "正常路径业";

this.正常路径业.ExecuteCode += new System.EventHandler(this.正常路径业_ExecuteCode);

//

// 支持取消的控件1

//

this.支持取消的控件1.Activities.Add(this.正常路径业);

this.支持取消的控件1.Activities.Add(this.cancellationHandlerActivity1);

this.支持取消的控件1.Name = "支持取消的控件1";

//

// 可取消的容器1

//

this.可取消的容器1.Activities.Add(this.支持取消的控件1);

this.可取消的容器1.Name = "可取消的容器1";

this.可取消的容器1.是否取消 = true;

//

// Workflow1

//

this.Activities.Add(this.可取消的容器1);

this.Name = "Workflow1";

this.CanModifyActivities = false;

}

 

private
void 正常路径业_ExecuteCode(object sender, EventArgs e)

{

System.Console.WriteLine("正常执行");

}

 

private
void 取消业务路径_ExecuteCode(object sender, EventArgs e)

{

System.Console.WriteLine("取消执行");

}

    }

 

宿主

class
Program

{

static
void Main()

{

WorkflowRuntime workflowRuntime = new
WorkflowRuntime();

workflowRuntime.WorkflowCompleted +=new
EventHandler<WorkflowCompletedEventArgs>(workflowRuntime_WorkflowCompleted);

workflowRuntime.WorkflowTerminated +=new
EventHandler<WorkflowTerminatedEventArgs>(workflowRuntime_WorkflowTerminated);

workflowRuntime.WorkflowIdled+=new
EventHandler<WorkflowEventArgs>(workflowRuntime_WorkflowIdled);

WorkflowInstance instance = workflowRuntime.CreateWorkflow(typeof(Workflow1));

instance.Start();

 

System.Console.Read();

 

}

 

static
void workflowRuntime_WorkflowIdled(object sender, WorkflowEventArgs e)

{

System.Console.WriteLine("WorkflowIdled");

}

 

static
void workflowRuntime_WorkflowTerminated(object sender, WorkflowTerminatedEventArgs e)

{

System.Console.WriteLine("Terminated" + e.Exception.Message);

}

 

static
void workflowRuntime_WorkflowCompleted(object sender, WorkflowCompletedEventArgs e)

{

System.Console.WriteLine("WorkflowCompleted");

}

 

}

 

运行结果