WeakHashMapの同時応用

ステップ1:グローバルWeakHashMap変数を生成

private static WeakHashMap lockMap = new WeakHashMap(50);

ステップ2:MAPからオブジェクトを取得します.あれば取り出し、なければMAPに新しく入れます

 /**
  *  ， 
  * 
  * @param key
  * @return
  */
 protected static Object getSynLockObject(String key) {
  synchronized (lockMap) {
  Object o = lockMap.get(key);
  if (o == null) {
  o = new Object();
  lockMap.put(key, o);
  }
  return o;
  }
 }

ステップ3:異なるオブジェクトをロックし、同じオブジェクトを同期できます.異なるオブジェクトは同時に実行できます

 public boolean processPaymentResult(YeepayResult result) {
  long orderSeqId = result.getOrderSeqId();
  //  Key ， ， key 
  String synLockKey = String.valueOf(orderSeqId);
  Object synLock = PayCenter.getSynLockObject(synLockKey);
  /**
  *  ， 
  */
  synchronized (synLock) {
  return synchroProcessPaymentResult(result);
  }
 }

例:同時の場合、データに対してプラス1操作を行い、データベースを挿入する

	private Map lockMap = new WeakHashMap(); //confirm every thread get lock object is the same object
	private String lockPrefix = this.getClass().getName()+"incrementSequenceNum";
	private int incrementSequenceNum(String sID, String tID, TopicIndexItem cacheTopic){
		String syn = lockPrefix + sID+tID;
		String value = lockMap.get(syn);
		if(value == null){
			synchronized(lockPrefix){
				if(lockMap.get(syn)==null){
					lockMap.put(syn, syn);
				}
			}
			value = lockMap.get(syn);
		}
		//syn = syn.intern();
		int sequenceNum = 0;
		synchronized(value){
			sequenceNum = DB.getTopicSequenceNum(sID, tID)+1;
			DB.incrementTopicSequenceNum(sID, tID);
			if(cacheTopic!=null){
				cacheTopic.setMaxSequenceNum(sequenceNum);
			}
		}
		return sequenceNum;
	}