0

是否有必要在 NetMQ 中作为订阅者顶部“锁定”

我想是的,我在下面做的点似乎是正确的地方吗?

   private void Subscribe()
    {
        using (var client = new SubscriberSocket())
        {
            client.Options.ReceiveHighWatermark = 1000;
            client.Connect(Connection);
            client.Subscribe(Key);

            while (true)
            {
                string address = client.ReceiveFrameString();
                lock (SubLock)
                {
                    int newSeqNum = int.Parse(client.ReceiveFrameString());
                    SendDTTxt = client.ReceiveFrameString();
                    string contents = client.ReceiveFrameString();

                    if (SeqNum == -1)
                        SeqNum = newSeqNum - 1;

                    if (newSeqNum != SeqNum + 1)
                    {
                        throw new Exception("[NetMTSub.Subscribe] SeqNum out of sequence");
                    }
                    SeqNum = newSeqNum;

                    UserAction(contents); 
                }
            }
        }
    }
4

1 回答 1

1

如您的评论中所述 - 订阅是从一个线程调用的:

由于仅从一个线程调用订阅,因此不需要锁定。

单个线程将无缘无故地按顺序锁定和解锁该代码块。

它可以安全地移除。

于 2018-10-11T09:58:32.070 回答