Threading дает неправильный аргумент

Question

У меня есть сервер, настроенный для прослушивания на порте для клиентов, а затем, если они найдут один, добавьте их в клиентский массив и послушайте их из другого потока.

Console.Write("Max Players: "); 
maxPlayers = Int32.Parse(Console.ReadLine()); 
clients = new TcpClient[maxPlayers]; 
playerCount = 0; 

formatter = new BinaryFormatter(); 
server = new TcpListener(IPAddress.Parse("192.168.1.33"), 7777); 
server.Start(); 

while (true) 
{ 
    if (server.Pending() && playerCount < maxPlayers) 
    { 
     Console.WriteLine("Found client"); 
     clients[playerCount] = server.AcceptTcpClient(); // Get client connection 
     //When one player joins, this should start a thread with an a playerCount of 0 
     Thread t = new Thread(() => ListenClient(playerCount)); 
     t.Start(); 
     playerCount++; 
    } 
} 

public static void ListenClient(int index) 
{ 
    while (true) 
    { 
     NetworkStream stream = clients[index].GetStream(); 
     object obj = formatter.Deserialize(stream); 

     if (obj != null) 
     { 
      Console.WriteLine(obj); 
     } 
    } 
} 

Однако, когда один игрок присоединяется, поток называется и передается аргумент 1, а не 0 по какой-то причине. В чем проблема?

Answer 1

Ну, вот как работает лямбда. Попробуйте вместо этого:

while (true) 
{ 
    if (server.Pending() && playerCount < maxPlayers) 
    { 
     Console.WriteLine("Found client"); 
     clients[playerCount] = server.AcceptTcpClient(); // Get client connection 
     //When one player joins, this should start a thread with an a playerCount of 0 
     int currentPlayersCount = playerCount; 
     Thread t = new Thread(() => ListenClient(currentPlayersCount)); 
     t.Start(); 
     playerCount++; 
    } 
} 

EDIT:

Как это было принято в качестве ответа, следует отметить, что сообщения DavidG и Андрея ниже дают дополнительную важную информацию о затворов, и следует читать, чтобы получить полная картина.

Answer 2

Альтернатива сообщению shay__ будет заключаться в использовании ParameterizedThreadStart.

Thread t = new Thread(new ParameterizedThreadStart((i) => ListenClient(i))); 
t.Start(playerCount); 
playerCount++; 

Answer 3

Проблема, которую вы видите здесь, связана с закрытием. Возьмите свой код выше, он переходит в переменную playerCount, а не значение этой переменной. последующие строки выполняются достаточно быстро, чтобы переменная увеличивалась до начала потока, поэтому значение равно 1. Чтобы решить эту проблему, вы можете скопировать значение локально в область действия блока if и передать это вместо этого:

int localPlayerCount = playerCount; 
Thread t = new Thread(() => ListenClient(localPlayerCount)); 

Дальнейшее чтение на затворах здесь: What are 'closures' in .NET?

Answer 4

отвечу больше вопроса здесь, практическая часть отвечает @shay__.

Проблема здесь в неправильном использовании clojure. Закрытие (лямбда в этом случае) не просто получает копию значения переменной в момент создания, но и получает ссылку на переменную, поэтому, когда вы действительно получаете значение (звонок ListenClient, вы получаете значение в тот момент времени (который 1). Это не очень интуитивным к тому, что C# команда made a breaking change и фиксированной он (или сделано более интуитивным) в C 5,0 #.

http://csharpindepth.com/Articles/Chapter5/Closures.aspx