1

我有以下内容：

   ThreadStart startThread =
     delegate
     {
             mySocket.StartListen();
     };

mySocket 现在在 Listen() 上循环，当我：

new Thread(startThread).Start();

这是开始监听：

public void StartListen()
{
 Object locker = new Object();

 // Lock resources
 lock (locker)
 {
  S = new System.Net.Sockets.Socket(System.Net.Sockets.AddressFamily.InterNetwork,
       System.Net.Sockets.SocketType.Stream,
       System.Net.Sockets.ProtocolType.Tcp);
  S.Blocking = false;

  try
  {
   S.Bind(serverEP);
   S.Listen(1000);
   isListening = true;

   /*
    * While statement not required here because AcceptConnection()
    * method instructs the socket to BeginAccept() again...
    */
   //while (true)
   //{
   connectDone.Reset();
   S.BeginAccept(new AsyncCallback(AcceptConnection), Channel);
   connectDone.WaitOne();
   //}
  }
  catch (System.Net.Sockets.SocketException SockEx)
  {
   Console.WriteLine("*****[" + name + "] " + SockEx.SocketErrorCode + ":");
   Console.WriteLine("*****[" + name + "] " + SockEx.Message);
  }
 }
}

由于异步方法，事情并没有真正“完成”并返回一个信号让其他任何事情继续。我在上面的 Thread.Start() 之后执行的任何命令都无法正常工作。例如，在 StartListen 中，请注意我有一个isListening = true. 启动线程后，我想使用属性 IsListening。它始终返回为 false。

我应该如何启动线程。异步方法（即 ThreadStart.BeginInvoke()）是否更可取？这不类似于使用 ManualResetEvent 吗？

4

1 回答 1

2

标记isListening为volatile。据我了解，您在两个不同的线程中引用了这个标志。通常，线程之间共享的数据必须同步，但您似乎没有这样做。但是，鉴于标志是 bool 类型，从技术上讲，您不必同步对它的访问，因为 .NET 框架保证从 bool 类型的读取和写入是原子的（我想我说得对......有人如果它在技术上不正确，请纠正我）。但是，为了确保从该类型读取的内容实际获得最新值，您需要将其标记为volatile.

此外，您最好使用TcpListener类而不是尝试对Socket类进行此操作。您所做的并没有错，但是TcpListener该类将使您的代码更易于阅读和维护，IMO。

最后，locker您正在使用的对象实际上并没有做任何事情，因为它是StartListen()方法的本地对象。为了使同步对象产生任何效果，它们需要可供需要对共享数据进行序列化访问的线程访问。您在此处执行此操作的方式，其他线程无法访问该locker变量，从而使其无用。

于 2009-11-17T17:59:15.267 回答