завершение потока, с шарп

[xelos]

в общем есть такой трабл.
есть класс, устанавливающий соединение через сокет. На сокет вешаю два стрима - на чтение и на запись (StreamWriter и StreamReader).
стрим на чтение зацикливаю на считывание строки в отдельном потоке.

все работает отлично до завершения программы. Поскольку объект класса с сокетом создается в классе формы, необходимо завершить поток при выходе из приложения. Ставил стандартный деструктор в классе с сокетом: ~IRCConnection() - управление в него никогда не передается

пробовал из класса формы в методе Dispose завершить поток через метод Abort - не завершается...

может кто подскажет в чем трабл? Стримы, кстати, тоже надо как-то закрывать, или они сами закроются?

[Serega]

Потоки(threads) лучше завершать естественным образом
лучше использовать флаг, но можно и Abort(MSDN)

Деструктор вызывается только когда происходит чистка мусора, при завершениии приложения машина просто возвращает память системе

When you are finished sending and receiving data, use the Shutdown method to disable the Socket. After calling Shutdown, call the Close method to release all resources associated with the Socket.

При закрытии потоков ввода/вывода вызывается метод flush, полезно если потоки буферизирующие

A call to Close is required for proper operation of a stream. Following a call to Close, other operations on the stream could throw exceptions. If the stream is already closed, a call to Close throws no exceptions.

[xelos]

упс, куда-то все делось?

[Dimka]

видимо, переехал сайт, могу повторить

нить - это поток команд, часто содержит цикл вида

Код:

...
while(!flag)
{
...
}
...
isclosed = true;
return;

управление через флаг - банальная установка flag = true. Тогда нить естественным образом завершится. Для гарантированного завершения дочерних нитей жди в главной нити установки флага isclosed. Это общее решение, специфики .NET в данном вопросе не знаю.

[xelos]

повторюсь, я делаю так:

Код:

public void Connect()
		{
			try
			{
				client=new TcpClient();
				client.Connect(host,port);
				ns=client.GetStream();

				Encoding enc=Encoding.GetEncoding(1251);
				
				rs=new StreamReader(ns,enc);
				ws=new StreamWriter(ns,enc);
												
				receiver = new Thread(new ThreadStart(ListenForMessages));
				receiver.Start();
				threadStarted=true;

			}
			catch (SocketException)
			{
								
			}
		}
		private void ListenForMessages()
		{
			while (threadStarted)
			{
				try
				{
					Rmessage=rs.ReadLine();
				}
				catch (Exception e)
				{
					string s=e.Message;
				}

				if (Rmessage!=null)
				{
					Message(Rmessage);
					if (Rmessage.StartsWith("PING"))
					{
						SendLine("PONG");
					}
				}
			}
			rs.DiscardBufferedData();
			rs.Close();
			ws.AutoFlush=true;
			ws.Close();
			ns.Flush();
			ns.Close();
			client.Close();

		}
		public void Stop()
		{
			threadStarted=false;
			if (receiver.ThreadState==ThreadState.Running)
                                  receiver.Abort();
		}

метод Stop() вызываю из формы при ее закрытии, проблема в линии:
Rmessage=rs.ReadLine();
нить блокирована ожиданием строки.
сообщения приходят асинхронно - т.е. непостоянно. И получается, что при вызове Stop нить не завершается в течение 20 секунд примерно. Вопрос теперь сводится к тому, как корректно мгновенно завершить потоки и нить.

[Serega]

Смотри NetworkStream: BeginRead/EndRead и BeginWrite/EndWrite

[xelos]

это, вроде, для асинхронных сокетов... у меня пока все через синхронные работает...