问访问websocket的多个线程

EN

// multiple trackers are calling in 
// for each tracker a thread is started calling this method
public static void SendPackageToClients(GpsTrackerEntry gte)
{

    var gteByteArray = Encoding.ASCII.GetBytes(Newtonsoft.Json.JsonConvert.SerializeObject(gte));

    foreach (var cs in AsynchronousSocketListener.carSubscriptions[gte.carId])
    {

        if (cs.Value.ws.State != WebSocketState.Open)
        {
            UnsubscribeClient(cs.Key);
            continue;
        }

        Task.Run( () => {
            // TODO: ideally here a thread should stop and wait for 
            // the target websocket to become available (i.e. no send or 
            // receive is being performed) and then execute the following method

            SendPackageToClient(cs.Value.ws, gteByteArray, cs.Key);
        });

    }
    return;
}

private static async void SendPackageToClient(WebSocket ws, byte[] gteByteArray, int key)
{

    try
    {

        await ws.SendAsync(gteByteArray, 0, true, CancellationToken.None);

        var timeOut = new CancellationTokenSource(5000).Token;

        byte[] ping = new byte[10];

        var result = await ws.ReceiveAsync(ping, timeOut);

        if (result.CloseStatus.HasValue)
        {
            Console.WriteLine(" **** CLIENT CLOSED CONNECTION **** ");
            UnsubscribeClient(key);
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine(" **** SERVER ERROR **** " + ex.Message);
        UnsubscribeClient(key);
    }
}