using system.collections.generic;
using system.linq;
using system.text;
using system.threading;
using system.runtime.remoting.messaging;
namespace consoleapplication1
{
public delegate int addhandler(int a, int b);
public class addmethod
{
public static int add(int a, int b)
{
console.writeline(开始计算: + a + + + b);
thread.sleep(3000); //模拟该方法运行三秒
console.writeline(计算完成!);
return a + b;
}
}
//**************同步调用***********
//委托的invoke方法用来进行同步调用。同步调用也可以叫阻塞调用,它将阻塞当前线程,然后执行调用,调用完毕后再继续向下进行。
//**************异步调用***********
//异步调用不阻塞线程,而是把调用塞到线程池中,程序主线程或ui线程可以继续执行。
//委托的异步调用通过begininvoke和endinvoke来实现。
//**************异步回调***********
//用回调函数,当调用结束时会自动调用回调函数,解决了为等待调用结果,而让线程依旧被阻塞的局面。
//注意: begininvoke和endinvoke必须成对调用.即使不需要返回值,但endinvoke还是必须调用,否则可能会造成内存泄漏。
class program
{
static void main(string[] args)
{
console.writeline(===== 同步调用 syncinvoketest =====);
addhandler handler = new addhandler(addmethod.add);
int result=handler.invoke(1,2);
console.writeline(继续做别的事情。。。);
console.writeline(result);
console.readkey();
console.writeline(===== 异步调用 asyncinvoketest =====);
addhandler handler1 = new addhandler(addmethod.add);
iasyncresult result1=handler1.begininvoke(1,2,null,null);
console.writeline(继续做别的事情。。。);
//异步操作返回
console.writeline(handler1.endinvoke(result1));
console.readkey();
console.writeline(===== 异步回调 asyncinvoketest =====);
addhandler handler2 = new addhandler(addmethod.add);
iasyncresult result2 = handler2.begininvoke(1, 2, new asynccallback(callback), null);
console.writeline(继续做别的事情。。。);
console.readkey();
//异步委托,也可以参考如下写法:
//action action=(obj)=>method(obj);
//action.begininvoke(obj,ar=>action.endinvoke(ar),null);
//简简单单两句话就可以完成一部操作。
}
static void callback(iasyncresult result)
{
addhandler handler = (addhandler)((asyncresult)result).asyncdelegate;
console.writeline(handler.endinvoke(result));
}
}
}