Я создаю проект, используя ZeroMQ. Мне нужны функции для запуска и завершения потока. Функция запуска работает нормально, но есть проблемы с функцией остановки.
private Thread _workerThread;
private object _locker = new object();
private bool _stop = false;
public void Start()
{
_workerThread = new Thread(RunZeroMqServer);
_workerThread.Start();
}
public void Stop()
{
lock (_locker)
{
_stop = true;
}
_workerThread.Join();
Console.WriteLine(_workerThread.ThreadState);
}
private void RunZeroMqServer()
{
using (var context = ZmqContext.Create())
using (ZmqSocket server = context.CreateSocket(SocketType.REP))
{
/*
var bindingAddress = new StringBuilder("tcp://");
bindingAddress.Append(_ipAddress);
bindingAddress.Append(":");
bindingAddress.Append(_port);
server.Bind(bindingAddress.ToString());
*/
//server.Bind("tcp://192.168.0.102:50000");
server.Bind("tcp://*:12345");
while (!_stop)
{
string message = server.Receive(Encoding.Unicode);
if (message == null) continue;
var response = ProcessMessage(message);
server.Send(response, Encoding.Unicode);
Thread.Sleep(100);
}
}
}
Может быть, кто-то знает об этой функции Stop(), почему она не убивает поток? Мне подсказали, что я должен использовать Thread.MemoryBarrier и volatile, но понятия не имею, как это должно работать. Так же есть функция ProcessMessage() для обработки сообщений, просто не стал копировать, чтобы не мусорить :)
