我们首先开发一个BusyFlag的类，类似于C++中的Simaphore。
| public class BusyFlag { protected Thread busyflag = null; protected int busycount = 0; public synchronized void getBusyFlag() { while (tryGetBusyFlag() == false) { try { wait(); } catch (Exception e) {} } } private synchronized boolean tryGetBusyFlag() { if (busyflag == null) { busyflag = Thread.currentThread(); busycount = 1; return true; } if (busyflag == Thread.currentThread()) { busycount++; return true; } return false; } public synchronized void freeBusyFlag() { if(getOwner()== Thread.currentThread()) { busycount--; if(busycount==0) { busyflag = null; notify(); } } } public synchronized Thread getOwner() { return busyflag; } } |
注：参考Scott Oaks & Henry Wong《Java Thread》
BusyFlag有3个公开方法：getBusyFlag, freeBusyFlag, getOwner，分别用于获取忙标志、释放忙标志和获取当前占用忙标志的线程。使用这个BusyFlag也非常地简单，只需要在需要锁定的地方，调用BusyFlag的getBusyFlag()，在对锁定的资源使用完毕时，再调用改BusyFlag的freeBusyFlag()即可。下面我们开始改造前面中的Account和ATM类，并应用BusyFlag工具类使得同时只有一个线程能够访问同一个账户的目标得以实现。首先，要改造Account类，在Account中内置了一个BusyFlag对象，并通过此标志对象对Account进行锁定和解锁：
| import java.util.Collections; import java.util.HashMap; import java.util.Map; class Account { String name; //float amount; BusyFlag flag = new BusyFlag(); //使用一个Map模拟持久存储 static Map storage = new HashMap(); static { storage.put("John", new Float(1000.0f)); storage.put("Mike", new Float(800.0f)); } static Map accounts = Collections.synchronizedMap(new HashMap()); private Account(String name) { this.name = name; //this.amount = ((Float)storage.get(name)).floatValue(); } public synchronized static Account getAccount (String name) { if (accounts.get(name) == null) accounts.put(name, new Account(name)); return (Account) accounts.get(name); } public synchronized void deposit(float amt) { float amount = ((Float)storage.get(name)).floatValue(); storage.put(name, new Float(amount + amt)); } public synchronized void withdraw(float amt) throws InsufficientBalanceException { float amount = ((Float)storage.get(name)).floatValue(); if (amount >= amt) amount -= amt; else throw new InsufficientBalanceException(); storage.put(name, new Float(amount)); } public float getBalance() { float amount = ((Float)storage.get(name)).floatValue(); return amount; } public void lock() { flag.getBusyFlag(); } public void unlock() { flag.freeBusyFlag(); } } |
新的Account提供了两个用于锁定的方法：lock()和unlock()，供Account对象的客户端在需要时锁定Account和解锁Account，Account通过委托给BusyFlag来提供这个机制。另外，大家也发现了，新的Account中提供了对Account对象的缓存，同时去除了public的构造方法，改为使用一个静态工厂方法供用户获取Account的实例，这样做也是有必要的，因为我们希望所有的ATM机同时只能有一个能够对同一个Account进行操作，我们在Account上的锁定是对一个特定Account对象进行加锁，如果多个ATM同时实例化多个同一个user的Account对象，那么仍然可以同时操作同一个账户。所以，要使用这种机制就必须保证Account对象在系统中的唯一性，所以，这儿使用一个Account的缓存，并将Account的构造方法变为私有的。你也可以说，通过在Account类锁上进行同步，即将Account中的BusyFlag对象声明为static的，但这样就使同时只能有一台ATM机进行操作了。这样，在一台ATM机在操作时，全市其它的所有的ATM机都必须等待。观看地址： http://www.qqread.com/java/w362884600.html 
更多内容请看Java环境安装配置、Java编程开发手册、Java的类专题，或进入讨论组讨论。
相关专题
- Java环境安装配置 (5627篇文章)
- Java编程开发手册 (8276篇文章)
- Java的类 (863篇文章)
- Java线程 (150篇文章)
- 掌握JAVA的标准 (26次浏览)
- JAVA编译时的常见错误 (25次浏览)
- Ubuntu Linux系统中Java环境的安装配置 (25次浏览)
- 如何在MyEclipse快速搭建Hibernate应用 (15次浏览)
- 高手为你分析类的设计方法 (12次浏览)
- Java中利用反射实现类的动态加载 (12次浏览)
- JAVA运行时的产间错误 (11次浏览)
- J2SE综合：浅谈java程序发布之 jre 篇 (11次浏览)
- Java敏捷开发技巧之消除代码异味 (10次浏览)
- JAVA代码中使用魔法数值 (8次浏览)
