zoukankan      html  css  js  c++  java
  • C# 对象锁

    现在有一种场景,服务端将一个任务派发给10个客户端执行,所有客户端执行完后,整个任务才算执行完。

    每个客户端执行完后,通过http发送一个完成的消息给服务端,服务端发送邮件通知给用户。

    当10个客户端同时发送完成请求的时候,服务端从数据库查询出来的客户端列表结果都还没有完成,可能会发送1~10封邮件。

    解决的办法是对任务ID加对象锁。

        //结果查询锁字典,根据id来加锁,当所有设备都完成的时候,此锁对象可废弃
            private static Dictionary<long, object> task_res_lockers = new Dictionary<long, object>();
            public object getLocker(long taskId)
            {
                if (!task_res_lockers.ContainsKey(taskId))
                {
                    task_res_lockers[taskId] = new Object();
                }
                return task_res_lockers[taskId];
            }
            public void removeLock(long taskId){
                if (task_res_lockers.ContainsKey(taskId))
                {
                    task_res_lockers.Remove(taskId);
                }
            }

    客户端返回执行结果的时候

    lock (agentResultDao.getLocker(taskId))
    {
         // 处理任务完成的逻辑
         // 当任务完成的时候  agentResultDao.removeLock(taskId) 释放对象引用
    } 

     lock关键字实际上是Monitor类的一个语法糖

    bool acquiredLock = false;
    
    try
    {
        Monitor.Enter(lockObject, ref acquiredLock);
    
        // Code that accesses resources that are protected by the lock.
    
    }
    finally
    {
        if (acquiredLock)
        {
            Monitor.Exit(lockObject);
        }
    }
  • 相关阅读:
    第五周学习总结-20175228
    第二周Java学习总结
    namke 命令行编译
    libssh2 的集成与应用
    vc6 编译问题
    vs2010 编译curl-7.42.1
    linux redis 安装
    解决error C2011: 'fd_set' : 'struct' type redefinition的方法
    ajax 的简单应用
    servlet 启动加载配置文件及初始化
  • 原文地址:https://www.cnblogs.com/tzyy/p/4744787.html
Copyright © 2011-2022 走看看