1、数据接口层：

package multithread;

public interface Data2 {

public abstract String getContent();
}

2、真实数据层：

package multithread;

public class RealData implements Data2{

private final String content;

public RealData(int count,char c){
   System.out.println(" making realdata("+count+","+c+") begin");
   char buffer[] = new char[count];
   for(int i=0;i<count;i++){
    buffer[i] = c;
    try {
     Thread.sleep(100);
    } catch (InterruptedException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
    }
   }
  
   System.out.println(" making realdata("+count+","+c+") end");
   this.content = new String(buffer);
}
public String getContent(){
   return content;
}
}

3、虚拟数据层（提货单）：

package multithread;

/**
* @author Administrator
*提货单
*/
public class FutureData implements Data2{

private RealData realdata = null;
private boolean ready = false;

public synchronized String getContent(){
   while(!ready){
    try {
     wait();
    } catch (InterruptedException e) {
     // TODO Auto-generated catch block
     e.printStackTrace();
    }
   }
  
   return realdata.getContent();
}

public synchronized void setRealData(RealData realdata){
   if(ready)
    return ;
   this.realdata = realdata;
   this.ready = true;
   notifyAll();
}
}

4、处理数据层：

package multithread;

public class Host2 {

public Data2 request(final int count,final char c){
   System.out.println(Thread.currentThread().getName()+" ....");
   System.out.println(" request("+count+", "+c+") begin");
   final FutureData future = new FutureData();
   //System.out.println(future.toString());
   new Thread(){
    public void run(){
     RealData realdata = new RealData(count ,c);
     future.setRealData(realdata);
    }
   }.start();
  
   System.out.println(" request("+count+", "+c+") end");
   return future;
}
}

5、测试类：

package multithread;

public class Main5 {

public static void main(String args[]){
   System.out.println("main begin");
   Host2 host = new Host2();
   Data2 data1 = host.request(10, 'A');
   Data2 data2 = host.request(20, 'B');
   Data2 data3 = host.request(30, 'C');
  
   System.out.println("main otherjob begin");
  
   try {
    Thread.sleep(2000);
   } catch (InterruptedException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
   System.out.println("main otherjob end");
  
   System.out.println("data1="+data1.getContent());
   System.out.println("data2="+data2.getContent());
   System.out.println("data3="+data3.getContent());
  
   System.out.println("main end");
}
}