Что происходит, если Вы убегаете из оператора Lock ()?
Я пишу программу, которая слушает входящий TcpClient и обрабатывает данные, когда они прибывают. Listen() метод выполняется на отдельном потоке в компоненте, таким образом, это должно быть ориентировано на многопотоковое исполнение. Если я break из a do while цикл, в то время как я в a lock() оператор, блокировка будет выпущена? В противном случае, как я выполняю это?
Спасибо!
(Любой другой совет на предмет Асинхронных Сокетов TCP приветствуется также.)
private void Listen()
{
do
{
lock (_clientLock)
{
if (!_client.Connected) break;
lock (_stateLock)
{
if (!_listening) break;
if (_client.GetStream().DataAvailable) HandleData();
}
}
Thread.Sleep(0);
} while (true);
}
5 ответов
Да. Оператор блокировки переводится в предложение try / finally. В C # 4, например, такой оператор блокировки:
lock(obj)
{
// body
}
примерно переводит ( из блога Эрика Липперта здесь ) в:
bool lockWasTaken = false;
var temp = obj;
try
{
Monitor.Enter(temp, ref lockWasTaken);
{
// body
}
}
finally
{
if (lockWasTaken)
Monitor.Exit(temp);
}
Когда выполнение выходит за пределы области блокировки { } , базовая блокировка снимается автоматически. Это произойдет независимо от того, как вы выйдете из области видимости (break / return / etc), поскольку вызов Monitor.Exit заключен внутри блока finally в try / finally.
Потому что вы просили другого совета ... Я заметил, что вы встраиваете блокировки. Само по себе это не обязательно плохо. Но это один из моих красных флажков, на который я обращаю внимание. Существует вероятность тупиковой ситуации, если вы когда-либо приобретете эти две блокировки в другом порядке в другой части вашего кода. Я не говорю, что с вашим кодом что-то не так. Это просто что-то еще, чего нужно остерегаться, потому что легко ошибиться.
Чтобы ответить на вторую половину вашего вопроса:
Любые другие советы на тему асинхронных TCP-сокетов также приветствуются
Проще говоря, я бы не стал решать эту задачу так, как показано в вашем оригинальном сообщении. Лучше обратитесь за помощью к классам System.Net.Sockets.TcpClient и System.Net.Sockets.TcpListener. Используйте асинхронные вызовы типа BeginAcceptSocket(...) и BeginRead(...) и позвольте ThreadPool делать свою работу. Это действительно очень легко собрать таким образом.
Вы должны быть в состоянии достичь всего поведения сервера, которое вы хотите, никогда не кодируя ужасные слова "new Thread" :)
Вот базовый пример идеи, за вычетом идеи изящного завершения работы, обработки исключений и т.д.:
public static void Main()
{
TcpListener listener = new TcpListener(new IPEndPoint(IPAddress.Loopback, 8080));
listener.Start();
listener.BeginAcceptTcpClient(OnConnect, listener);
Console.WriteLine("Press any key to quit...");
Console.ReadKey();
}
static void OnConnect(IAsyncResult ar)
{
TcpListener listener = (TcpListener)ar.AsyncState;
new TcpReader(listener.EndAcceptTcpClient(ar));
listener.BeginAcceptTcpClient(OnConnect, listener);
}
class TcpReader
{
string respose = "HTTP 1.1 200\r\nContent-Length:12\r\n\r\nHello World!";
TcpClient client;
NetworkStream socket;
byte[] buffer;
public TcpReader(TcpClient client)
{
this.client = client;
socket = client.GetStream();
buffer = new byte[1024];
socket.BeginRead(buffer, 0, 1024, OnRead, socket);
}
void OnRead(IAsyncResult ar)
{
int nBytes = socket.EndRead(ar);
if (nBytes > 0)
{
//you have data... do something with it, http example
socket.BeginWrite(
Encoding.ASCII.GetBytes(respose), 0, respose.Length, null, null);
socket.BeginRead(buffer, 0, 1024, OnRead, socket);
}
else
socket.Close();
}
}
Для гораздо более сложного примера того, как это сделать, смотрите SslTunnel Library, которую я написал некоторое время назад.
Да, блокировка будет снята. Вы можете использовать ILDASM или Reflector для просмотра фактического сгенерированного кода. Оператор блокировки является сокращением для следующего кода (примерно).
Monitor.Enter(_client);
try
{
// do your stuff
}
finally {
Monitor.Exit(_client);
}
Обратите внимание, что блок finally всегда выполняется.
Как только вы выйдете из блокировки {} , он разблокирует то, что вы заблокировали (в этом отношении это похоже на оператор using). Неважно, где вы выходите (начало, конец или середину), дело в том, что вы вообще вышли из области действия блокировки. Подумайте, что произойдет, если вы вызовете исключение посередине.