昨天我遇到了一个奇怪的问题,这让我很头疼。我有一个带有server类的服务器应用程序,而这个类又派生自Connection类。Connection类提供有关连接状态和关闭连接的可能性的信息
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类适用于实际发送数据
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?中的回调时,似乎确实存在类似的问题,但这里的情况有点不同,因为在我的情况下(我认为),锁中的代码不应该发出任何事件,这些事件本身会试图获得对象上的锁。
发布于 2014-02-14 17:07:01
让我们假设它首先在第二个方法中获得了锁。所以它持有锁,并等待数据。目前还不清楚这是直接接收由第一种方法发送的数据,还是寻找来自无关服务器的回复-对第一种方法发送的消息的回复。但无论哪种方式,我都假设在发送出站消息之前不会有数据传入。
现在考虑一下:出站消息无法发送,因为您持有排它锁。
不需要在入站和出站套接字操作之间进行同步,即使在同一套接字上也是如此。由于在同一套接字上具有并发读取器或并发写入器的意义不大,因此我猜您实际上根本不需要这些lock。
https://stackoverflow.com/questions/21774886
复制相似问题