java实现异步调用实例

java实现异步调用实例

在JAVA平台,实现异步调用的角色有以下三个角色:
 
调用者 取货凭证   真实数据
 
一个调用者在调用耗时操做,不能当即返回数据时,先返回一个取货凭证.而后在过一断时间后
凭取货凭证来获取真正的数据.
 
因此连结调用者和真实数据之间的桥梁是取货凭证.咱们先来看它的实现:
 
public class FutureTicket{
 private Object data = null;
 private boolean completed = false;
 
 public synchronized void makeRealData(){
  if(this.complited) return;
  //获取数据的耗时操做.这里用Sleep代替
  try{
   Thread.sleep(10000);
  }catch(Throwable t){}
  this.data = "返回的数据内容";
  this.completed = true;
  notifyAll();
 }
 
 public synchronized Object getData(){
  while(!this.completed)){
   try{
    wait();
   }catch(Throwable t){}
  }
  return this.data;
  
 }
 public boolean isCompleted(){
  return this.completed;
 }
}
 
为了简单化说明(不把它们的关系开得复杂),这里用Objec tb 代替了真实数据.而真实的实现中咱们应该把makeData放在一个真实数据的类中,而后提供一个方法返回真实数据.这样对于真实数据的处理和取货凭证解耦. 对于这个取货凭证,调用者的如何调用是异步调用的关键: publc class Requester{ public FutureTicket request(){  final FutureTicket ft = new FutureTicket();    //在新线程中调用耗时操做  new Thread(){   public void run(){    ft.makeRealData();   }  }.start();  return ft; }}在新线程中启动耗时操做后,不等待线程的完成当即返回提货单. 而后调用者能够根据ft.isCompleted()来调用getData()获取真实数据.固然对ft.isCompleted()测试能够按规定时间间隔轮巡(极低级的方案),也能够在条件不知足时wait(),而后等待makeData的notifyAll();这样你就完成了一个用JAVA模拟的异步操做. 改进:但这样的调用对于调用者来讲仍然要继续控制线程操做.若是调用者是一个资深的程序员,这固然没有问题.但假如咱们把对直接数据的处理委托给取货凭证来作.调用者直接规定对数据的操做,而后由取货凭证来调用规定的操做,这对于调用者是一个很好的解脱: interface ProcessData{ public void process(Onject data);} public MyProcessData{ public void process(Object data){  //你无论何时起初数据data被获取了.  //你只要规定若是获取到数据了如何处理    System.out.println(data.toString() + "处理完成...........");  //insert into dataBase? }} 取货凭证在接收调用者请求获取数据时,要知道对获取的数据如何处理的方法: public class FutureTicket{ private Object data = null; private boolean completed = false; private ProcessData pd;  public FutureTicket(ProcessData pd){  this.pd = pd; } public synchronized void makeRealData(ProcessData pd){  if(this.complited) return;  //获取数据的耗时操做.这里用Sleep代替  try{   Thread.sleep(10000);  }catch(Throwable t){}  this.data = "返回的数据内容";  this.completed = true;  notifyAll(); }  public synchronized void putData(){  while(!this.completed)){   try{    wait();   }catch(Throwable t){}  }  //return this.data;  //不用返回了,直接处理  this.pd.process(this.data);  // alert(?);   }  //这个方法也能够不要了. public boolean isCompleted(){  return this.completed; }} 调用:   final FutureTicket ft = new FutureTicket(new ProcessData());    //在新线程中调用耗时操做  new Thread(){   public void run(){    ft.makeRealData();   }  }.start();  ft.putData(); OK,你如今能够抽烟,喝酒,泡妞.ft会为你完成全部的工做.