让服务器同时处理两个线程

Question

我有两个线程在稍微不同的时间到达服务器程序中的一个点，都发送一个字符串。我希望服务器此时暂停，直到两个线程都收到一个字符串，然后继续。目前我正在使用Console.ReadKey(); 来“暂停”线程。但这不是解决方案，因为我需要按两次键（每个线程一个键）才能继续。

是否有可能在程序类中有一个全局计数器，所有线程随时都可以访问和编辑？与ConcurrentDictionary 类似的概念。这样我就可以根据哪个线程首先发送字符串来区分线程，并使程序挂起，直到计数器对两个客户端都“应答”感到满意。

class Program
{
    public static bool isFirstThread = false;

    static void Main(string[] args)
    {
        runServer();
    }

    static void runServer()
    {
        //server setup
        Thread[] threadsArray = new Thread[2];
        int i = 0;
        try
        {
            while(true) //game loop
            {
                Socket connection;
                connection = listener.AcceptSocket();
                threadRequest = new Handler();

                if(i==0) //first thread
                {
                    threadsArray[i] = new Thread(() => threadRequest.clientInteraction(connection, true);
                }
                else //not first thread
                {
                    threadsArray[i] = new Thread(() => threadRequest.clientInteraction(connection, false);
                }

                threadsArray[i].Start();
                i++;
            }
        }

        catch(Exception e)
        {
            Console.WriteLine("Exception: " + e.ToString());
        }
    }
}


class Handler 
{
    public void clientInteraction(Socket connection, bool isFirstThread)

    {
        string pAnswer = string.Empty;
        //setup streamReaders and streamWriters

        while(true) //infinite game loop
        {
            //read in a question and send to both threads.
            pAnswer = sr.ReadLine();
            Console.WriteLine(pAnswer);

            Console.ReadKey(); //This is where I need the program to hang

            awardPoints(); 

        }
    }
}   

这是我的代码在做什么的粗略概念，为了避免问题膨胀，我已经切了很多东西，所以我可能遗漏了一些错误的东西。

理论上我可以从服务器发送问题字符串时开始设置一个计时器，但我宁愿不在这个阶段。

任何想法或指示将不胜感激。提前致谢。

Answer 1

使用System.Threading.Barrier，它是专门为这个目的而设计的：让一组线程中的每个线程等待，直到它们都达到计算中的某个点。像这样在runServer() 中初始化它：

Barrier barrier = new Barrier(2);

并在每个线程的末尾执行此操作：

barrier.SignalAndWait();