Java多线程同步中的两个特殊类 - 编程入门网
| f (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》 Java多线程同步中的两个特殊类(4)时间:2007-11-05BusyFlag有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的构造方法变为 |
凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢! |
