现在有一种场景，服务端将一个任务派发给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);
}
}