Нужна небольшая помощь с кодом (.NET, Win) - не могу сообразить

[e-statik]

Пишу обработчик CAN шины под винду, в Visual Studio, C#.
Раньше под винду и потоки не писал ничего, пытаюсь разобраться, было много опыта только с ASP.NET, сижу буксую... (

Цель - слушать порт 64888.
Для этого худо бедно осилил запуск потока и чтение в нем сообщений через UdpClient - данные получаю и обрабатываю. Но не могу правильно тормознуть чтение, поставить на паузу. Либо целиком выключить созданный поток и соединение в нём.

Пересмотрел много код снипетов, но пока что-то не заработало, делаю явно неправильно.

Помогите пож! Конкретно хочу мочь ставить чтение на паузу, а так же мочь вообще корректно выключить прослушивание порта и корректно завершить поток.

Ниже код, который удалось наваять.

Код в форме:

// Это срабатывает, когда в радиобатоне выбирается "Слушать/не слушать"
if (thisRadioButton.Checked) // Начать прослушивание
{
MainWorker = new UdpWorker();
MainWorker.handlerMessageReceived = ReceiverMessage; // привязал метод, кот. будет дергаться в форме на каждом сообщении

MainThreadDelegate = new ThreadStart(MainWorker.DoWork);
MainThread = new Thread(MainThreadDelegate);
MainThread.Start();
}
else // Остановить прослушивание
{
MainWorker.RequestStop();
}



Код собственно чтения - полуфабрикат, ищу правильное решение:

public class UdpWorker
{
private const int listenPort = 64888;
private UdpClient listener;

private volatile bool _shouldStop;

public delegate void MessageReceived(CanRxMsg msg);
public MessageReceived handlerMessageReceived;

public void DoWork()
{
listener = new UdpClient(listenPort);
IPEndPoint groupEP = new IPEndPoint(IPAddress.Loopback, listenPort);

try
{
while (!_shouldStop)
{
byte[] bytes = listener.Receive(ref groupEP);
if (bytes == null || bytes.Length == 0)
break;

dataHandler(bytes); // Этот метод уже выдаст сообщение наружу, его код не привожу, к проблеме мало относится
}
}
catch (ThreadAbortException)
{

}
finally
{
//listener.Client.Disconnect(false);
//listener.Client.Shutdown(SocketShutdown.Both);
//listener.Client.Dispose();
//listener.Close();
}
}

public void RequestStop()
{
listener.Client.Shutdown(SocketShutdown.Receive);
listener.Client.Close();
_shouldStop = true;
}
}

[e-statik]

Сейчас добрался до того, что на десктопе конкретно запинается на
byte[] bytes = listener.Receive(ref groupEP);

Т.е. фактически ничего по порту не проходит, он ждёт. В принципе, всё правильно. Но как его корректно снаружи пнуть, чтобы он перестал слушать - не могу сообразить.

Пытался дёрнуть что-то вроде
listener.Client.Disconnect
или
listener.Client.Shutdown
получаю ошибки, что-то не то делаю...

[e-statik]

Программистов нет совсем? (((

[Илия]

Помогите пож! Конкретно хочу мочь ставить чтение на паузу, а так же мочь вообще корректно выключить прослушивание порта и корректно завершить поток.


http://msdn.microsoft.com/en-us/library/tttdef8x.aspx
Пишут:

Calling Thread.Sleep with Timeout.Infinite causes a thread to sleep until it is interrupted by another thread that calls Thread.Interrupt, or until it is terminated by Thread.Abort.

[e-statik]

Наверное, можно было бы тогда вообще вызывать Thread.Abort.
И создавать новый, когда снова надо слушать порт.

Но я попробовал - вызывал Thread.Abort, а потом заново попытался создать. Эксепшн: ругается на уже открытое соединение по этому порту. Явно зависает на listener.Receive.
Где-то проскакивало, что лучше использовать не устаревший Receive, а BeginReceive и EndReceive (или как-то так).

[e-statik]

Короче, похоже, что разбираться нужно скорее не с потоками, а с UdpClient и правильной работой с ним. Так, видимо...
Ну или всё же надо как-то корректно вырубить поток, чтобы он сам отключил соединения и всё остальное, что успел запустить инстанс UdpClient. И тупой Thread.Abort этого явно не делает.

[Илия]

закрывай слушателя и чисти ресурсы. Сначала Close потом Dispose.

[Илия]

надо как-то корректно вырубить поток, чтобы он сам отключил соединения и всё остальное

Он этого делать за тебя не будет! :big:

[e-statik]

О... заработало что ли

Сделал так:
MainWorker.RequestStop();
MainThread.Abort();

а в RequestStop:
listener.Client.Close();
listener.Client.Dispose();
_shouldStop = true;

И стало нормально запускаться и глушиться.

Спасибо!

[Илия]

Рад помочь!