异步调用轻量级封装AsynCaller-阿里云开发者社区

开发者社区> zhuweisky> 正文

异步调用轻量级封装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接口事件的事件处理函数也是在后台线程中调用的,也存在同样的问题。


版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
C/C++封装库ocicpplib调用Oracle存储过程的方法
工作这么多年,一直使用Mysql, Oracle数据库没有接触过, 这次要使用C/C++语言来调用Oracle的存储过程, 懒得自己去看OCI的API了, 直接上网找别人封装的库, 最后发现了这个ocicpplib, 下载了看了一下, 还不错, 使用起来比较简单。
1067 0
阿里云服务器怎么设置密码?怎么停机?怎么重启服务器?
如果在创建实例时没有设置密码,或者密码丢失,您可以在控制台上重新设置实例的登录密码。本文仅描述如何在 ECS 管理控制台上修改实例登录密码。
7238 0
阿里云服务器如何登录?阿里云服务器的三种登录方法
购买阿里云ECS云服务器后如何登录?场景不同,大概有三种登录方式:
2503 0
阿里云新版人脸识别Go语言调用示例
本文主要演示基于阿里云现有通用Http Go SDK调用阿里云新版人脸识别服务,以DetectFace方法为示例演示。
1200 0
C++ 调用lib 和 dll的 方法 及 动态库DLL与静态库lib的区别
C++ 调用.lib的方法: 一: 隐式的加载时链接,有三种方法     1  LIB文件直接加入到工程文件列表中   在VC中打开File View一页,选中工程名,单击鼠标右键,然后选中"Add Files to Project"菜单,在弹出的文件对话框中选中要加入DLL的LIB文件。
3037 0
C++ 静态调用C的DLL库(调用lib文件)
C++ 静态调用C的DLL库(调用lib文件)
15 0
+关注
zhuweisky
从事软件开发行业十多年,专注于网络通信技术和网络语音视频技术,擅长系统架构设计、系统性能优化等。zhuweisky.cnblogs.com
300
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
《Nacos架构&原理》
立即下载
《看见新力量:二》电子书
立即下载
云上自动化运维(CloudOps)白皮书
立即下载