Синхронизация подключенных клиентов

...
public event EventHandler<RequestRecieveEventArgs> RequestRecieve;
private readonly int _Port;
private Socket tcpListener;
...
private async void ListeningAsync()
        {
            var Listener = tcpListener;
            Socket tcpСlient = null;
 
            try
            {
                Console.SetCursorPosition(0, 2);
                Console.WriteLine($"Сервер (порт {_Port}) запущен. Ожидание подключений... ");
 
                while (_Enabled)
                {
                    tcpСlient = await Listener.AcceptAsync();
                    ProcessRequestAsync(tcpСlient);
                }
                            
            }
            catch (SocketException) { Console.WriteLine("Fatal error server...."); }
        }
  
        private async void ProcessRequestAsync(Socket client)
        {
            await Task.Run(() => RequestRecieve?.Invoke(this, new RequestRecieveEventArgs(client)));
        }
...

 public static void Run()
        {
            Program.tcpServer.RequestRecieve += TcpServer_RequestRecieve;
            Program.tcpServer.Enabled = true;
 
            while (Program._WorkServer)
            {
                if (Program.Clients.Count != 0)
                {
                    //Установит все объекты синхронизации
 
                    ...
 
                    // Дождаться завершения всех задач в такте
                    ... 
                }
                else
                {
                    Thread.Sleep(100);
                }
            }
            Console.ReadLine();
 
        }

        private static void TcpServer_RequestRecieve(object sender, RequestRecieveEventArgs e)
        {
 
            try
            {                
                var client = e.TcpClient;
                NetworkStream networkStream = new NetworkStream(client);
 
                while (Program.Work)
                {
                    List<DataPackage> dataPackages = DbWork._getDataTbl(Program.NRec);
                    
                    waitHandleThisClientStart.WaitOne();
 
                    if (dataPackages.Count != 0)
                    {
                        ...
                        // отправляем данные
                        networkStream.Write(response, 0, response.Length);
                        
                    }
                    else
                    {
                        byte[] buffer = { 0x00 };
                        networkStream.Write(buffer, 0, buffer.Length);
                    }
 
                    waitHandleThisClientStart.Reset();
                    waitHandleThisClientStop.Set();
                }
                
            }
            catch(Exception ex)
            {
                Console.WriteLine(ex.ToString());
                return;
            }
        }

//только переименуйте переменную
waitHandleThisClientStart.WaitOne();

var timer = new PeriodicTimer(TimeSpan.FromSeconds(2));
while (await timer.WaitForNextTickAsync(CancellationToken.None))
{
    waitHandleThisClientStart.Reset();
    // собрать всех клиентов и через TPL отправить сообщения
    var tasks = ....
    await Task.WhenAll(tasks);
    waitHandleThisClientStart.Set();
}