java 多线程synchronized同步锁锁住相同用户Id

2022-05-20 15:01:41 阅读：185 来源： 互联网

标签：mMapIdCache java HashMap synchronized mMapId userId oldId 多线程

java 多线程synchronized同步锁锁住相同用户Id
转载：https://www.csdn.net/tags/Ntjakg3sMjg0MDUtYmxvZwO0O0OO0O0O.html

本文介绍使用java synchronized同步锁来实现对相同userId进行加锁

众所周知synchronized只能锁对象地址，而对于如下加锁是完全没有用的

    public void test(Long userId) {
        synchronized (userId) {//除了-127-128外其他的值都锁不住
//            ...
        }
    }

原因就在于±127之外的都是new除来的Long（见源码Long.valueOf），地址值当然不一样了。

既然synchronized需要同一个对象，那我们将同一对象缓存下来不就得了。

    private HashMap<Long, Long> mMap = new HashMap<>();
    public Long getLock(Long userId) {
        if (!mMap.containsKey(userId)) {
            mMap.put(userId, userId);
        }
        return mMap.get(userId);
    }

思路是对的，但：getLock本身就会有并发问题；每个需要锁的接口都得new一个全局的HashMap；当10000个用户调用了100个接口总计要保存1000000条userId在内存里，服务器运行时间越长积累越多。

于是改成了如下方式，代码虽长了一点，但效率几乎没有下降：

/**
 * 由于synchronized只能锁对象的地址，所有像Long为1000的用户id是锁不住的
 * 此类来解决这个问题
 * synchronized (UserLockUtils.getLock("test" + userId)) {}
 * 因为是全局的入参当然是"接口名+userId"最好了
 */
public class UserLockUtils {
    private static HashMap<String, String> mMapId = new HashMap<>(), mMapIdCache = new HashMap<>();
    /**
     * 缓存切换的开始时间，等待{@link #mCacheDeleteTime}时间后将清空切换数据
     */
    private static long mCacheCreatTime;
    /**
     * 最大缓存数(当超出这一数值时，会自动清空)，缓存切换等待时间
     */
    private static int mMaxCache = 1000, mCacheDeleteTime = 10000;

    public static synchronized String getLock(String oldId) {
        String returnSt;
        if (mMapId.size() < mMaxCache) {//数据比较少，普通的返回锁
            if (!mMapId.containsKey(oldId)) {
                mMapId.put(oldId, oldId);
            }
            returnSt = mMapId.get(oldId);
        } else {//累加的残留数据太多，切换至缓存
            //缓存开始时间
            long nowMills = System.currentTimeMillis();
            if (mMapIdCache.size() == 0) {
                mCacheCreatTime = nowMills;
            }

            if (!mMapIdCache.containsKey(oldId)) {
                mMapIdCache.put(oldId, mMapId.getOrDefault(oldId, oldId));
            }
            returnSt = mMapIdCache.get(oldId);

            //等待mCacheChangeTime时间后清除原始数据
            if (nowMills - mCacheCreatTime > mCacheDeleteTime) {
                mMapId.clear();
                //原始和缓存对调即可实现切换
                HashMap<String, String> change = mMapId;
                mMapId = mMapIdCache;
                mMapIdCache = change;
            }
        }
        return returnSt;
    }
}

举例：登录接口，我们只需要传“接口名+userId”就可以对登录接口的userId加锁了。

    public void login(Long userId) {
        synchronized (UserLockUtils.getLock("login" + userId)) {
//            ...
        }
    }

尽量不要直接传userId哦，如果所有接口都直接传userId估计就锁死了。

标签：mMapIdCache,java,HashMap,synchronized,mMapId,userId,oldId,多线程
来源： https://www.cnblogs.com/yhc-love-cl/p/16292292.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

java 多线程synchronized同步锁锁住相同用户Id