c#异步通信中回调函数AsyncCallback如何传递参数

调用回调函数的语句
AsyncCallback callBack = new AsyncCallback(sendCallBack);
frd.socket.BeginSend(msg, 0, msg.Length, SocketFlags.None, callBack, frd); AsyncCallback callBack = new AsyncCallback(sendCallBack);
frd.socket.BeginSend(msg, 0, msg.Length, SocketFlags.None, callBack, frd);
回调函数如下:
private void sendCallBack(IAsyncResult ar)
{
MyFriends frd = (MyFriends)ar.AsyncState;
try
{
frd.socket.EndSend(ar);
}
catch (System.Exception ex)
{
comBox_client.Invoke(removeFriend,comBox_client, friends,frd);
}
}
显然,回调函数用有个变量是:comBox_client,这两段代码写在一个类里面没有什么问题,但是我如果需要分开在两个类里面呢?需要将comBox_client传进去。。。有办法吗

写一个类,将你要的参数都封装进去。然后通过IAsyncResult.AsyncState进行传递。

// 1)定义类,封装你要的任何东西
class StateObject
{
    public Socket frd{get;set;}
    pubic ComboBox combo{get;set;}
    //可以添加任何你需要的东西
    //……
}

// 2)在异步调用前,实例化StateObject
StateObject state = new StateObject();
state.frd = frd;
state.combo = comBox_client;
AsyncCallback callBack = new AsyncCallback(sendCallBack);
frd.socket.BeginSend(msg, 0, msg.Length, SocketFlags.None, callBack, state);

//3)在回调函数中使用StateObject
private void sendCallBack(IAsyncResult ar)
{
    StateObject state = (StateObject)ar.AsyncState;
    //从 state中 取出frd, combo ……
    Socket frd = state.frd;
    ComboBox combo = state.combo;
    try
     {
         frd.EndSend(ar);
     }
     catch (System.Exception ex)
     {
        combo.Invoke(removeFriend, combo, friends,frd)     
     }
}

追问

谢谢!!非常感谢,原来奥秘在最后一个参数中。。。。

追答

不客气~~ ^_^

温馨提示:内容为网友见解,仅供参考
第1个回答  2016-01-18
代码段1:
public delegate string FuncHandle(int data1, int data2);
FuncHandle fh ;

private void BT_Temp_Click(object sender, RoutedEventArgs e)
{
fh = new FuncHandle(this.Foo);
AsyncCallback callback = new AsyncCallback(this.AsyncCallbackImpl);
fh.BeginInvoke(1, 3, callback, null);
}
public void AsyncCallbackImpl(IAsyncResult ar)
{
string re = fh.EndInvoke(ar);
MessageBox.Show("" + ar.AsyncState);
}

string Foo(int data1, int data2)
{
return "" + data1 + data2;
}

在异步调用中,如果想在异步的回调函数中,得到异步函数的返回值(如上面代码中的Foo函数的string返回值),则必须要在回调函数中使用EndInvoke(关于EndInvoke会在下文描述)。在上面的例子是如下这句。
string re = fh.EndInvoke(ar);

但是,有的时候fh并不见得是个类变量,这个时候,就需要将EndInvoke的执行主体由BeginInvoke传递进去。看修改过后的代码片段。

代码段2:
public delegate string FuncHandle(int data1, int data2);

private void BT_Temp_Click(object sender, RoutedEventArgs e)
{
FuncHandle fh = new FuncHandle(this.Foo);
AsyncCallback callback = new AsyncCallback(this.AsyncCallbackImpl);
fh.BeginInvoke(1, 3, callback, fh);
}
public void AsyncCallbackImpl(IAsyncResult ar)
{
FuncHandle dl = ar.AsyncState as FuncHandle;
string re = dl.EndInvoke(ar);
MessageBox.Show("" + ar.AsyncState);
}

string Foo(int data1, int data2)
{
return "" + data1 + data2;
}

通过举一反三,其实BeginInvoke的最后一个参数,可以是任何对象,看具体的应用场景即可。

下面再介绍一下EndInvoke。EndInvoke在回调函数中,用于承载执行的主体函数的返回值。在另外一个情况下,即上面的代码片段一个简化版本,如下:

代码段3:
public delegate string FuncHandle(int data1, int data2);
private void BT_Temp_Click(object sender, RoutedEventArgs e)
{
FuncHandle fh = new FuncHandle(this.Foo);
IAsyncResult ar = fh.BeginInvoke(1, 3, null, fh);
string re = fh.EndInvoke(ar);
MessageBox.Show(re);
}

string Foo(int data1, int data2)
{
return "" + data1 + data2;
}

可以看到,在这个代码片段中,根本没有使用回调函数,那么,就需要通过EndInvoke来阻滞主线程,使得返回函数主体的返回值。

再多说一点,调用了 BeginInvoke 后,可以:

1.进行某些操作,然后调用 EndInvoke 一直阻塞到调用完成。如上文的最后一个代码片段。
2.使用 IAsyncResult.AsyncWaitHandle 获取 WaitHandle,使用它的 WaitOne 方法将执行一直阻塞到发出 WaitHandle 信号,然后调用EndInvoke。这里主要是主程序等待异步方法,等待异步方法的结果。见代码段4。
3.轮询由 BeginInvoke 返回的 IAsyncResult,IAsyncResult.IsCompeted确定异步调用何时完成,然后调用 EndInvoke。
4.将用于回调方法的委托传递给 BeginInvoke。该方法在异步调用完成后在 ThreadPool 线程上执行,它可以调用 EndInvoke。这是在强制装换回调函数里面IAsyncResult.AsyncState(BeginInvoke方法的最后一个参数)成委托,然后用委托执行EndInvoke。即如上代码片段2。

代码段4:
public delegate string FuncHandle(int data1, int data2);
string _sTemp = string.Empty;
private void BT_Temp_Click(object sender, RoutedEventArgs e)
{
FuncHandle fh = new FuncHandle(this.Foo);
AsyncCallback callback = new AsyncCallback(this.AsyncCallbackImpl);
IAsyncResult ar = fh.BeginInvoke(1, 3, null, null);
WaitHandle waitHandle = ar.AsyncWaitHandle;
waitHandle.WaitOne();
MessageBox.Show(_sTemp);
}
string Foo(int data1, int data2)
{
Thread.Sleep(3000);
string re = "" + data1 + data2;
_sTemp = re;
return re;
}

c#异步通信中回调函数AsyncCallback如何传递参数
写一个类,将你要的参数都封装进去。然后通过IAsyncResult.AsyncState进行传递。\/\/ 1)定义类,封装你要的任何东西class StateObject{ public Socket frd{get;set;} pubic ComboBox combo{get;set;} \/\/可以添加任何你需要的东西 \/\/……}\/\/ 2)在异步调用前,实例化StateObjectStateObject ...

c# 异步怎么回调
textBox1.Text = n.ToString();\/\/ 参数n就是异步回调返回的结果,} 异步回调需要编写代码才能支持,网络传输方面的类库一般都提供异步方法,如socket编程,web服务,ajax,wcf等,有些异步是同一个线程完成的,有些异步是不同的线程,所以回调函数里要更新控件都会提示跨线程访问控件的错误提示。该文章...

如何:使用回调方法实现异步 Web 服务客户端
回答:该方法在“与 XML Web 服务进行异步通信”主题中说明。本示例基于包含方法 Factorize 的 Web 服务类 PrimeFactorizer,Wsdl.exe 工具为该类生成了两个异步客户端代理方法 BeginFactorize 和 EndFactorize。实现回调方法定义实现 AsyncCallback 委托的回调函数。C#publicstaticvoid FactorizeCallback(...

C#socket异步怎么实现 线程间通信如何实现
socket.BeginConnect(iep, new AsyncCallback(Connect),socket); EndConnect是一种阻塞方法,用于完成BeginConnect方法的异步连接诶远程主机的请求。在注册了回调函数后必须接收BeginConnect方法返回的IASynccReuslt作为参数。下面为代码演示:复制代码void Connect(IAsyncResult iar){ Socket client=(Socket)iar.AsyncState; try...

C#networkstream.beginread与endread的问题
异步访问一般用于读写时间较长的操作,顾名思义,BeginRead()就是开始读,并立即返回,不会等待执行完。这个函数的最后两个参数比较特殊,是专用于异步的,一个是AsyncCallback ,它是个委托,用于回调异步调用结束后的自定义函数,另一个是Object,用于传递需要的参数给你的自定义函数的,一般在你的自...

C#同步方法和异步方法的区别
(1)BeginInvoke方法用于启动异步调用 它与您需要异步执行的方法具有相同的参数,只不过还有两个额外的参数,将 AsyncCallback 和 AsyncState(可通过 IAsyncResult 接口的AsyncState 属性获得)作为最后两个参数,如没有可以为空.BeginInvoke立即返回,不等待异步调用完成。BeginInvoke返回IasyncResult,可用于监视...

C#异步,什么叫做回调方法? IAsyncResult这个类是干什么的
通俗来讲:回调函数就是你传一个函数指针A,也就是C#里的委托,给另一函数B,然后B中条件被触发时,就调用A。void B( delegate void A ){ ...if(...){A;} } IAsyncResult是接口,里面有几个属性用来查看可以查看异步操作的状态:AsyncState获取用户定义的对象,它限定或包含关于异步操作的信息...

C#异步编程由浅入深:Async\/Await的作用
在C#中,它是以状态机的形式表现的,每个状态都对应一部分代码。状态机有一个MoveNext()方法,根据不同的状态执行不同的代码,然后每个状态部分对应的代码都会设置下一个状态字段,然后将自身的MoveNext()方法放到类似ContinueWith()的函数中去执行,整个状态机由回调函数推动。我们尝试手动转换以下async\/...

C#异步调用的好处和方法分享
\/\/异步完成时,执行的方法(回调方法),此方法只能有IAsyncResult一个参数,但是该参数几乎万能,可以传递object privatevoidCallBackMethod(IAsyncResultar){ \/\/从异步状态ar.AsyncState中,获取委托对象 DelegateNamedn=(DelegateName)ar.AsyncState;\/\/输出参数 inti;\/\/一定要EndInvoke,否则你的下场很惨 s...

C#中回调 Callback
private void Loader1(){ HttpWebRequest hrqt=(HttpWebRequest)WebRequest.Create("http:\/\/msdn2.microsoft.com\/zh-cn\/default.aspx");hrqt.Proxy=(IWebProxy)new WebProxy(proxyip_string,port_int);IAsyncResult iar=(IAsyncResult)hrqt.BeginGetResponse(new AsyncCallback(ResponseCallback),hrqt...

相似回答