首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >在专用锁对象上锁定会导致死锁

问在专用锁对象上锁定会导致死锁
EN

Stack Overflow用户
提问于 2014-02-14 17:00:32
回答 1查看 465关注 0票数 0

昨天我遇到了一个奇怪的问题,这让我很头疼。我有一个带有server类的服务器应用程序,而这个类又派生自Connection类。Connection类提供有关连接状态和关闭连接的可能性的信息

代码语言:javascript
复制
public bool Connected
{
    get
    {
        if (connection != null)
        {
            lock (lockObject)
            {
                bool blockingState = connection.Blocking;

                try
                {
                    connection.Blocking = false;
                    connection.Send(new byte[1], 1, 0);
                }
                catch (SocketException e)
                {
                    if (!e.NativeErrorCode.Equals(10035))
                    {
                        return false;
                    }
                     //is connected, but would block

                }
                finally
                {
                    connection.Blocking = blockingState;
                }

                return connection.Connected;

            }

        }

        return false;
   }
}

public virtual void CloseConnection()
{
    if (Connected)
    {
        lock (lockObject)
        {
            connection.Close();
        }
    }
}

Server类适用于实际发送数据

代码语言:javascript
复制
private void ConnectAndPollForData()
{
    try
    {
        TcpListener listener = new TcpListener(Port);

        listener.Start();
        while (true)
        {
            connection = listener.AcceptSocket();

            string currentBuffr = string.Empty;
            const int READ_BUFFER_SIZE = 1024;
            byte[] readBuffr = new byte[READ_BUFFER_SIZE];

            while (Connected)
            {
                int bytesReceived;

                lock (lockObject)
                {
                    bytesReceived = connection.Receive(readBuffr, READ_BUFFER_SIZE, SocketFlags.None);
                }
                currentBuffr += ASCIIEncoding.ASCII.GetString(readBuffr, 0, bytesReceived);

                //do stuff

        }
    }
    catch(ThreadAbortException)
    {
        Thread.ResetAbort();
    }
    finally
    {

    }
}

public void SendString(string stringToSend)
{
    stringToSend += "\r\n";


    if(Connected)
    {
        lock(lockObject)
        {
            connection.Send(ASCIIEncoding.UTF7.GetBytes(stringToSend));
        }
    }

}

没有对connection对象的其他显式访问。ConnectAndPollForData函数在单独的线程中执行。每当我在这个版本中运行主机时(我当前使用的是非线程安全版本,这会导致其他问题),它在通过TCP接收到相当多的行之后挂起。暂停调试器向我显示,一个线程试图使用Connected锁执行代码,而另一个线程试图接收ConnectAndPollForData锁中的数据。这种行为对我来说似乎很奇怪,因为我希望在第一个锁中执行代码,然后执行第二个锁。在使用Deadlocking lock() method或'Deadlock' with only one locked object?中的回调时,似乎确实存在类似的问题,但这里的情况有点不同,因为在我的情况下(我认为),锁中的代码不应该发出任何事件,这些事件本身会试图获得对象上的锁。

EN

回答 1

Stack Overflow用户

发布于 2014-02-14 17:07:01

让我们假设它首先在第二个方法中获得了锁。所以它持有锁,并等待数据。目前还不清楚这是直接接收由第一种方法发送的数据,还是寻找来自无关服务器的回复-对第一种方法发送的消息的回复。但无论哪种方式,我都假设在发送出站消息之前不会有数据传入。

现在考虑一下:出站消息无法发送,因为您持有排它锁。

不需要在入站和出站套接字操作之间进行同步,即使在同一套接字上也是如此。由于在同一套接字上具有并发读取器或并发写入器的意义不大,因此我猜您实际上根本不需要这些lock。

票数 4
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/21774886

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档