异步调用轻量级封装AsynCaller

简介:     当UI动作引发一个耗时的计算时,我们经常需要将这个耗时的过程放到后台线程中去完成,然后获取该过程的结果。使用.NET提供的默认设施,无论是使用Thread还是使用异步调用,细节都比较繁琐。

 

    当UI动作引发一个耗时的计算时,我们经常需要将这个耗时的过程放到后台线程中去完成,然后获取该过程的结果。使用.NET提供的默认设施,无论是使用Thread还是使用异步调用,细节都比较繁琐。在前几天的blog上也看到了有些兄台的解决方案,但是觉得还不够好用,于是自己封了一个AsynCaller。
    AsynCaller通过事件来通知外部异步调用的结果,IAsynCaller接口如下:

    public   interface  IAsynCaller
    {
        
// Delegate用于动态调用目标方法
         void  Initialize(Delegate method , object [] args) ;

        
void  Start() ;   // 启动异步操作
         void  Cancel() ;  // 取消操作

        
event  CBackTaskCompleted   TaskCompleted ;
        
event  CBackExceptionThrown ExceptionThrown ;
        
event  CBackTaskCanceled    TaskCanceled ;
    }

    
public   delegate   void  CBackTaskCompleted( object  result) ;
    
public   delegate   void  CBackExceptionThrown(Exception ee) ;
    
public   delegate   void  CBackTaskCanceled() ;


    上面的接口清晰易懂,所需要注意的就是Initialize方法,它的第一个参数是需要进行异步调用的目标方法的委托,Delegate就像一个万能的delegate,它可以匹配到任何签名的方法。
    接口出来后,其实现AsynCaller就很容易写了。


public class AsynCaller :IAsynCaller
    {
        
private Delegate target  = null;
        
private object[] theArgs = null;        
        
private Thread   backThread = null ;
        
private bool     canceled = false ;

        
private CBackTaskCompleted     taskCompleted;
        
private CBackExceptionThrown exceptionThrown;
        
private CBackTaskCanceled    taskCanceled ;
        
        
#region IAsynCaller 成员
        
public void Initialize(Delegate method ,object[] args)
        {
            
this.target = method ;
            
this.theArgs = args ;
        }

        
public void Start()
        {
            
this.backThread = new Thread(new ThreadStart(this.BackThread)) ;
            
this.backThread.Start() ;
        }

        
public void Cancel()
        {    
            
this.canceled = true ;
            
this.backThread.Abort() ;
        }

        
#region BackThread
        
private void BackThread()
        {
            
try
            {
                
object result = this.target.DynamicInvoke(this.theArgs) ;//动态调用
                this.ActivateTaskCompleted(result) ;
            }
            
catch(Exception ee)
            {
                
if((this.canceled) || (ee is ThreadAbortException)) //任务被取消
                {
                    
this.ActivateTaskCanceled() ;
                }
                
else
                {
                    
this.ActivateExceptionThrown(ee) ;
                }
            }
        }
        
#endregion
        
        
#region event
        
private void ActivateTaskCompleted(object result)
        {
            
if(this.taskCompleted != null)
            {
                
this.taskCompleted(result) ;
            }
        }

        
private void ActivateExceptionThrown(Exception ee)
        {
            
if(this.exceptionThrown != null)
            {
                
this.exceptionThrown(ee) ;
            }
        }

        
private void ActivateTaskCanceled()
        {
            
if(this.taskCanceled != null)
            {
                
this.taskCanceled() ;
            }
        }

        
public event CBackTaskCompleted TaskCompleted
        {
            add
            {
                
this.taskCompleted += value ;
            }
            remove
            {
                
this.taskCompleted -= value ;
            }
        }

        
public event CBackTaskCanceled TaskCanceled
        {
            add
            {
                
this.taskCanceled += value ;
            }
            remove
            {
                
this.taskCanceled -= value ;
            }
        }

        
public event CBackExceptionThrown ExceptionThrown
        {
            add
            {
                
this.exceptionThrown += value ;
            }
            remove
            {
                
this.exceptionThrown -= value ;
            }
        }
        
#endregion

        
#endregion

    }


    下面给出一个示例来说明如何使用IAsynCaller。
    比如在一个Form中,有两个按钮,一个用于启动异步调用,一个用于取消操作。首先写一个耗时的方法,用于异步调用:

        private   void  ComputeTask( int  count)
        {
            
for ( int  i = 0  ;i <  count ;i ++ )
            {
                Thread.Sleep(
500 ) ;
                
this .label1.Text  =   string .Format( " 第{0}次 "  ,i) ;
            }
        }

    然后在Form中添加成员变量:

private  IAsynCaller theAsynCaller  =   null  ;

    在构造函数中,初始化theAsynCaller,并预定对应的事件:

            object [] args  =  { 30 } ;
            
this .theAsynCaller  =   new  AsynCaller() ;
            
this .theAsynCaller.Initialize( new  CBack1( this .ComputeTask) ,args) ;

            
this .theAsynCaller.TaskCanceled  +=   new  CBackTaskCanceled(theAsynCaller_TaskCanceled);
            
this .theAsynCaller.TaskCompleted  += new  CBackTaskCompleted(theAsynCaller_TaskCompleted);

    事件处理函数如下:

        private   void  button1_Click( object  sender, System.EventArgs e)
        {
            
this .theAsynCaller.Start() ;
        }

        
private   void  button2_Click( object  sender, System.EventArgs e)
        {
            
this .theAsynCaller.Cancel() ;
        }

        
private   void  theAsynCaller_TaskCanceled()
        {
            MessageBox.Show(
" Task Canceled " ) ;
        }

        
private   void  theAsynCaller_TaskCompleted( object  result)
        {
            MessageBox.Show(
" Task complete " ) ;
        }


    为了简化,上面的示例在后台线程中调用的了UI显示,这在真正的应用中是万万不可的。同时要注意,上面的示例中,IAsynCaller接口事件的事件处理函数也是在后台线程中调用的,也存在同样的问题。


目录
相关文章
|
6天前
|
存储 关系型数据库 分布式数据库
PostgreSQL 18 发布,快来 PolarDB 尝鲜!
PostgreSQL 18 发布,PolarDB for PostgreSQL 全面兼容。新版本支持异步I/O、UUIDv7、虚拟生成列、逻辑复制增强及OAuth认证,显著提升性能与安全。PolarDB-PG 18 支持存算分离架构,融合海量弹性存储与极致计算性能,搭配丰富插件生态,为企业提供高效、稳定、灵活的云数据库解决方案,助力企业数字化转型如虎添翼!
|
17天前
|
弹性计算 关系型数据库 微服务
基于 Docker 与 Kubernetes(K3s)的微服务:阿里云生产环境扩容实践
在微服务架构中,如何实现“稳定扩容”与“成本可控”是企业面临的核心挑战。本文结合 Python FastAPI 微服务实战,详解如何基于阿里云基础设施,利用 Docker 封装服务、K3s 实现容器编排,构建生产级微服务架构。内容涵盖容器构建、集群部署、自动扩缩容、可观测性等关键环节,适配阿里云资源特性与服务生态,助力企业打造低成本、高可靠、易扩展的微服务解决方案。
1320 7
|
5天前
|
存储 人工智能 Java
AI 超级智能体全栈项目阶段二:Prompt 优化技巧与学术分析 AI 应用开发实现上下文联系多轮对话
本文讲解 Prompt 基本概念与 10 个优化技巧,结合学术分析 AI 应用的需求分析、设计方案,介绍 Spring AI 中 ChatClient 及 Advisors 的使用。
296 129
AI 超级智能体全栈项目阶段二:Prompt 优化技巧与学术分析 AI 应用开发实现上下文联系多轮对话
|
4天前
|
监控 JavaScript Java
基于大模型技术的反欺诈知识问答系统
随着互联网与金融科技发展,网络欺诈频发,构建高效反欺诈平台成为迫切需求。本文基于Java、Vue.js、Spring Boot与MySQL技术,设计实现集欺诈识别、宣传教育、用户互动于一体的反欺诈系统,提升公众防范意识,助力企业合规与用户权益保护。
|
16天前
|
机器学习/深度学习 人工智能 前端开发
通义DeepResearch全面开源!同步分享可落地的高阶Agent构建方法论
通义研究团队开源发布通义 DeepResearch —— 首个在性能上可与 OpenAI DeepResearch 相媲美、并在多项权威基准测试中取得领先表现的全开源 Web Agent。
1388 87
|
4天前
|
JavaScript Java 大数据
基于JavaWeb的销售管理系统设计系统
本系统基于Java、MySQL、Spring Boot与Vue.js技术,构建高效、可扩展的销售管理平台,实现客户、订单、数据可视化等全流程自动化管理,提升企业运营效率与决策能力。
|
5天前
|
人工智能 Java API
AI 超级智能体全栈项目阶段一:AI大模型概述、选型、项目初始化以及基于阿里云灵积模型 Qwen-Plus实现模型接入四种方式(SDK/HTTP/SpringAI/langchain4j)
本文介绍AI大模型的核心概念、分类及开发者学习路径,重点讲解如何选择与接入大模型。项目基于Spring Boot,使用阿里云灵积模型(Qwen-Plus),对比SDK、HTTP、Spring AI和LangChain4j四种接入方式,助力开发者高效构建AI应用。
276 122
AI 超级智能体全栈项目阶段一:AI大模型概述、选型、项目初始化以及基于阿里云灵积模型 Qwen-Plus实现模型接入四种方式(SDK/HTTP/SpringAI/langchain4j)
|
5天前
|
弹性计算 安全 数据安全/隐私保护
2025年阿里云域名备案流程(新手图文详细流程)
本文图文详解阿里云账号注册、服务器租赁、域名购买及备案全流程,涵盖企业实名认证、信息模板创建、域名备案提交与管局审核等关键步骤,助您快速完成网站上线前的准备工作。
231 82
2025年阿里云域名备案流程(新手图文详细流程)