为了账号安全,请及时绑定邮箱和手机立即绑定

关于c#异步通信中回调函数AsyncCallback该如何传递参数?有什么方法吗?

关于c#异步通信中回调函数AsyncCallback该如何传递参数?有什么方法吗?

拉丁的传说 2022-01-04 21:14:53
调用回调函数的语句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传进去。。。有办法吗
查看完整描述

2 回答

?
郎朗坤

TA贡献1921条经验 获得超9个赞

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


// 1)定义类,封装你要的任何东西class StateObject{    public Socket frd{get;set;}    pubic ComboBox combo{get;set;}    //可以添加任何你需要的东西    //……} // 2)在异步调用前,实例化StateObjectStateObject 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)在回调函数中使用StateObjectprivate 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)          }}


查看完整回答
反对 回复 2022-01-10
?
炎炎设计

TA贡献1808条经验 获得超4个赞

代码段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;
}



查看完整回答
反对 回复 2022-01-10
  • 2 回答
  • 0 关注
  • 530 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
微信客服

购课补贴
联系客服咨询优惠详情

帮助反馈 APP下载

慕课网APP
您的移动学习伙伴

公众号

扫描二维码
关注慕课网微信公众号