c# - 如果中间有外部 api 调用,如何处理 lock 语句

标签 c# asp.net concurrency

我有以下代码:

private static HashSet<SoloUser> soloUsers = new HashSet<SoloUser>();

    public void findNewPartner(string School, string Major)
    {
        lock (soloUsers)
        {
            SoloUser soloUser = soloUsers.FirstOrDefault(s => (s.School == School) && (s.Major == Major));
            MatchConnection matchConn;
            if (soloUser != null)
            {
                if (soloUser.ConnectionId != Context.ConnectionId)
                {                                                                     
                    soloUsers.Remove(soloUser);
                }

            }
            else
            {   string sessionId = TokenHelper.GenerateSession();                                     

                soloUser = new SoloUser
                {
                    Major = Major,
                    School = School,
                    SessionId = sessionId,
                    ConnectionId = Context.ConnectionId
                };

                soloUsers.Add(soloUser);


            }

        } 

    }

TokenHelper.GenerateToken(soloUser.Session)TokenHelper.GenerateModeratorToken(session); 可能很危险,因为它们可能需要一些时间才能生成 token 。这将暂时锁定所有用户,这可能是一个问题?这个逻辑是否有任何解决方法,以便我仍然可以保持所有线程安全?

编辑: 我删除了 TokenHelper.GenerateToken(soloUser.Session) 和 TokenHelper.GenerateModeratorToken(session) ,因为我意识到它们可能发生在锁之外,但每个 SoloUser 有一个名为 SessionId 的属性,该属性是为每个用户生成的。 GenerateSession 方法也需要一些时间。每个用户在添加到集合之前都需要拥有这些 SessionId 之一

最佳答案

如果您有能力获得两次锁定,并且偶尔会生成一个 sessionId 但从未使用过也没关系,那么您可以将GenerateSession移出锁定。

类似这样的事情:

 public void findNewPartner(string School, string Major)
    {
        SoloUser soloUser = null;

        lock (soloUsers)
        {
            soloUser = soloUsers.FirstOrDefault(s => (s.School == School) && (s.Major == Major));
        }

        string sessionId = null;

        // will we be creating a new soloUser?
        if (soloUser == null)
        { 
            // then we'll need a new session for that new user
            sessionId = TokenHelper.GenerateSession();
        }

        lock (soloUsers)
        {
            soloUser = soloUsers.FirstOrDefault(s => (s.School == School) && (s.Major == Major));
            if (soloUser != null)
            {
                // woops! Guess we don't need that sessionId after all.  Oh well! Carry on...
                if (soloUser.ConnectionId != Context.ConnectionId)
                {                                                                     
                    soloUsers.Remove(soloUser);
                }

            }
            else
            {   
                // use the sessionid computed earlier
                soloUser = new SoloUser
                {
                    Major = Major,
                    School = School,
                    SessionId = sessionId,
                    ConnectionId = Context.ConnectionId
                };

                soloUsers.Add(soloUser);

        }

    } 

这基本上会进行快速锁定,以查看是否需要构造新的soloUser,如果需要,那么我们需要生成一个新 session 。新 session 的生成发生在锁之外。然后我们重新获取锁并执行原来的一组操作。当构造一个新的soloUser时,它使用在锁之外构造的sessionId。

此模式可能会生成从未使用过的 sessionId。如果两个线程同时执行此函数,且学校和专业相同,则两个线程都会生成 session id,但只有其中一个线程会成功创建一个新的 soloUser 并将其添加到集合中。失败的线程将在集合中找到soloUser并将其从集合中删除 - 并且不使用它刚刚生成的sessionId。此时,两个线程都将引用具有相同 sessionId 的同一个 soloUser,这似乎就是目标。

如果 sessionId 具有与其关联的资源(例如数据库中的条目),但当 sessionId 过期时这些资源将被清除,那么像这样的冲突将产生一些额外的噪音,但总体上不会影响系统。

如果生成的 sessionId 没有任何需要清理或老化的关联,那么您可能会考虑丢失我的示例中的第一个锁,并且始终生成一个 sessionId,无论是否需要。这可能不太可能发生,但我之前在特殊情况下使用过这种“混杂”的技巧,以避免跳进跳出高流量锁。如果创建成本低而锁定成本高,那么就放弃创建并小心锁定。

确保GenerateSession的成本足够高,足以证明这种额外的运行是合理的。如果GenerateSession需要纳秒才能完成,那么您不需要所有这些 - 只需将其保留在最初编写的锁中即可。如果GenerateSession需要“很长一段时间”(一秒或更长?500毫秒或更多?不能说),那么将其移出锁是一个好主意,可以防止共享列表的其他使用必须等待。

关于c# - 如果中间有外部 api 调用,如何处理 lock 语句,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/11636198/

相关文章:

c# - 读取 Outlook .msg 文件

c# - ASP.NET CommandArgument Eval 可以包含 2 列吗?

java - 使用 IKVM 将 JAR 文件转换为 .DLL 时的警告

c# - 如何每天重置应用程序变量

java - 我如何首先重新提供 LinkedBlockingQueue 中的项目?

c# - 将机器人框架 Luis 与 QnA 作为 Intent 集成,然后在进入 QnA 后重新询问用户

c# - 在不同的服务器上查找目录

python - concurrent.futures 问题 : why only 1 worker?

Javascript 信号量/测试和设置/锁定?

c# - 虚拟方法/属性的分支