jdk5.0多线程学习笔记(二)
在学习jdk5的新特性之前,先看一个多线程的模式:Future Pattern去蛋糕店买蛋糕,不需要等蛋糕做出来(假设现做要很长时间),只需要领个提货单就可以了(去干别的事情),等到蛋糕做好了,再拿提货单取蛋糕就可以了。future模式与这个场景类似。
假设有一个需要执行一段时间的方法,我们可以不必等待结果出来,而是获取一个替代的“提货单”。因为获取“提货单”不需要花时间,这时这个“提货单”就是future参与者。
获取future参与者的线程会在事后再去获取执行结果,就好像拿提货单去取蛋糕一样。如果有执行结果了,就可以马上拿到数据。如果没有结果,就等到有结果。
下面看一段代码:
public class Main { public static void main(String[] args) { System.out.println("main BEGIN"); Host host = new Host(); Data data1 = host.request(10, 'A'); Data data2 = host.request(20, 'B'); Data data3 = host.request(30, 'C'); System.out.println("main otherJob BEGIN"); try { Thread.sleep(200); } catch (InterruptedException e) { } 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"); }} 这里的main类就相当于“顾客”,host就相当于“蛋糕店”,顾客向“蛋糕店”定蛋糕就相当于“发请求request”,返回的数据data就相当于“提货单”而不是真正的“蛋糕”。在过一段时间后(sleep一段时间后),再去凭“提货单”取蛋糕“data1.getContent()”。
下面来看一下,顾客定蛋糕后,蛋糕店做了什么:
public class Host { public Data request(final int count, final char c) { System.out.println(" request(" + count + ", " + c + ") BEGIN"); // (1) 建立FutureData的实体 final FutureData future = new FutureData(); // (2) 为了建立RealData的实体,启动新的线程 new Thread() { public void run() { RealData realdata = new RealData(count, c); future.setRealData(realdata); } }.start(); System.out.println(" request(" + count + ", " + c + ") END"); // (3) 取回FutureData实体,作为传回值 return future; }} host("蛋糕店")在接到请求后,先生成了“提货单”FutureData的实例future,然后命令“蛋糕师傅”RealData去做蛋糕,realdata相当于起个线程去做蛋糕了。然后host返回给顾客的仅仅是“提货单”future,而不是蛋糕。当蛋糕做好后,蛋糕师傅才能给对应的“提货单”蛋糕,也就是future.setRealData(realdata)。
下面来看看蛋糕师傅是怎么做蛋糕的:
public class RealData implements Data { private final String content; public RealData(int count, char c) { System.out.println(" making RealData(" + count + ", " + c + ") BEGIN"); char[] buffer = new char; for (int i = 0; i < count; i++) { buffer = c; try { Thread.sleep(1000); } catch (InterruptedException e) { } } System.out.println(" making RealData(" + count + ", " + c + ") END"); this.content = new String(buffer); } public String getContent() { return content; }} 现在来看看“提货单”future是怎么与蛋糕"content"对应的:
public class FutureData implements Data { private RealData realdata = null; private boolean ready = false;//将提货单与蛋糕师傅对应也就是与蛋糕对应,一个蛋糕师傅做一个订单 public synchronized void setRealData(RealData realdata) { if (ready) { return; // balk } this.realdata = realdata; this.ready = true; notifyAll(); } public synchronized String getContent() { while (!ready) { try { wait(); } catch (InterruptedException e) { } } return realdata.getContent(); }}
顾客做完自己的事情后,会拿着自己的“提货单”来取蛋糕:
System.out.println("data1 = " + data1.getContent()); 这时候如果蛋糕没做好,就只好等了:
while (!ready) { try { wait(); } catch (InterruptedException e) { }//等做好后才能取到return realdata.getContent();
本文只是简单介绍一下future pattern,本人也是初学,如果要深入了解,还需要研究研究,本文代码并不优,只是做个说明性的例子。在以后将继续学习多线程。
页:
[1]