1. struct  PrinterImp : Printer{
2.     virtual   void  printString( const  ::std::string& s,
3.         const  ::Ice::Current&)
4.     {
5.         Sleep(1000);
6.         cout << s << endl;   
7.     }
8. };

异步方法分派(Asynchronous Method Dispatch，简称AMD)

AMD是针对服务器端而言的，在同步的情况下，服务器端收到一个调用请求后，在线程池中拿出一个空闲线程用于执行这个调用。这样，服务器在同一时刻所能支持的同步请求数受到线程池大小的限制。

如果线程池内的线程都在忙于执行长时间的操作，那么新的请求到来时就会处于长时间得不到答复的状态，这可能会造成客户端长时间等待（如果客户端没使用AMI的话）。

ICE的解决方法是：服务器收到请求时并不马上执行具体工作，而是把执行这项工作所需的参数以及回调类保存到一个地方（比如队列）后就返回。而另外的线程（或线程池）负责取出保存的参数并执行之，执行结束后使用回调类通知客户端工作已完成（或异常）。

还是用上面“斧头帮”来举例：“斧头帮”大哥（客户端）叫小弟（服务器端）去干收租的活（远程调用），这位小弟并不是马上就去收租去了，而是把这件 工作记录到他的日程表里（同时还有好几个老板叫他干活呢，可怜的人啊~~）。然后等有空的时候再按日程表一项项的做（或者叫其它有空的弟兄帮忙做），做完 工作后该放烟花的就放烟花（回调智能客户端），该砍人的就放信号弹啥的。

例：修改原Helloworld 服务器端，使用异步方法分派处理printString方法。

首先，要修改原来的Printer.ice定义文件，在printString方法前加上["amd"]元标识符。

    module Demo{
    interface Printer
    {
        ["amd" ]  void  printString(string s);
    };
    };

同样，再用slice2cpp Printer.ice生成Printer.h和Printer.cpp文件，并把这两个文件加入原项目（如果是直接修改之前的代码的话，因为原先已经加入了这两个文件，这步可以跳过）。

观察生成的Printer.h文件，可以发现和AMI类似的一个回调接口AMD_Printer_printString ：

 namespace  Demo
 {
 
 class  AMD_Printer_printString :  virtual   public  ::IceUtil::Shared
 {
 public :
 
     virtual   void  ice_response() = 0;
     virtual   void  ice_exception( const  ::std::exception&) = 0;
     virtual   void  ice_exception() = 0;
 };
 ...
 }

这个回调接口由ICE自己实现，我们只要拿来用就可以了。在哪里用呢？马上就会发现：我们要实现的Printer接口的printString 方法不见了，取而代之的是printString_async 方法：

   namespace  Demo
   {
   class  Printer :  virtual   public  ::Ice::Object
   {
       ...
       virtual   void  printString_async(
           const  ::Demo::AMD_Printer_printStringPtr&,
           const  ::std::string&,  const  ::Ice::Current& = ::Ice::Current()) = 0;
       ...
   };
   }

这个printString_async 方法就是我们要实现的异步分派方法，它的第一个参数就是由ICE实现的回调类AMD_Printer_printString ，在这个方法里，我们要两种方案：

1. 直接做具体工作，完成后在末尾调用回调类的ice_response方法告知客户端已完成。这种方案就和之前普通版的服务端一样，是同步执行的。
2. 把 回调类和请求所需要的参数放入一个指定的位置，再由其它线程取出执行和通知客户端。这种方案就是异步分派方法，具体实现时还可以有多种方式，如使用命令模 式把参数和具体操作直接封装成一个对象放入队列，然后由另一线程（或线程池）取出执行。后面的示例代码为了简单起见直接使用了Windows API中的线程池功能，而且也没有使用队列。

示例代码

 #include <ice/ice.h>
 #include "printer.h"
 
 using   namespace  std;
 using   namespace  Demo;
 
 // 传递给线程函数的参数
 struct  CallbackEntry{
     AMD_Printer_printStringPtr callback;
     string str;
 };
 
 // 线程函数
 DWORD  WINAPI DoPrintString( LPVOID  lpParameter)
 {
     // 取得参数
     CallbackEntry *pCE = (CallbackEntry *)lpParameter;
     // 工作：打印字符（延时1秒模拟长时间操作）
     Sleep(1000);
     cout << pCE->str << endl;  
     // 回调，工作完成。如果工作异常，则调用ice_exception();
     pCE->callback->ice_response();
     // 删除参数（这里使用堆直接传递，其实更好的方法是使用队列）
     delete  pCE;
     return  TRUE;
 }
 
 struct  PrinterImp : Printer{
     virtual   void  printString_async(
         const  AMD_Printer_printStringPtr &callback,
         const  string& s,  const  Ice::Current&)
     {
         // 参数打包（回调类和pringString方法的参数）
         CallbackEntry *pCE = new  CallbackEntry;
         pCE->callback = callback;
         pCE->str = s;
         // 让Windows线程池来执行具体任务
         ::QueueUserWorkItem(DoPrintString,pCE,WT_EXECUTEDEFAULT);
     }
 };
 
 class  MyApp :  public  Ice::Application{
 public :
     virtual   int  run( int  n,  char * v[]){
         Ice::CommunicatorPtr& ic = communicator();
         Ice::ObjectAdapterPtr adapter
             = ic->createObjectAdapterWithEndpoints("SP" , "default -p 10000" );
         Ice::ObjectPtr object = new  PrinterImp;
         adapter->add(object, ic->stringToIdentity("SimplePrinter" ));
 
         adapter->activate();
         ic->waitForShutdown();
         return  0;
     }
 };
 
 int  main( int  argc,  char * argv[])
 {
     MyApp app;
     return  app.main(argc, argv);
 }

客户端不需要改变，编译运行服务器然后用客户端测试效果。(其实效果不是很明显，因为AMD提高的是服务器的负荷能力)