Esperando múltiples solicitudes POST asíncronas

Question

Necesito realizar varias llamadas asíncronas desde un servicio wcf alojado en IIS (podría ser relevante, no sé). Las llamadas son a otros servicios, pero las realizo enviando una cadena a la URL del servicio. Llamarlos sincrónicamente funciona, pero tengo más de una docena de llamadas, y son completamente independientes, por lo que me gustaría acelerarlas llamándolos de forma asíncrona.

Ahora, me doy cuenta de que simplemente podría usar varios hilos para esto, y podría ser la solución más fácil, pero pensé que podría intentarlo de forma asíncrona.

Mi código es similar a esto:

public delegate void Callback(string response); 

public static void InvokeAsync(string request, string url, Callback callback) 
    where TResponse: class 
{ 
    var web = new WebClient(); 
    web.Headers.Add("Content-Type", "application/x-www-form-urlencoded"); 

    web.UploadStringCompleted += (sender, e) => callback.Invoke(e.Result); 
    web.UploadStringAsync(new Uri(url), request); 
} 

//... 
var lockObj = new object(); 
foreach (var item in list) 
    InvokeAsync(item, url, response => { lock(lockObj) newList.Add(response); }); 

lo anterior debe funcionar, creo; sin embargo, mi problema es que no tengo idea de cómo esperar hasta que todas las respuestas estén de vuelta. Si uso un contador y espero en un bucle hasta que llegue a cero, no quedará ninguna CPU para manejar las devoluciones de llamada. Lo mismo con usar alguna forma de semáforo, creo. ¿Hay una forma no bloqueante de esperar hasta que haya recuperado todas las respuestas? (Cambio de la firma del método tomar también una devolución de llamada sólo se moverá el problema a un nivel superior, me temo.)

[Editar] Aquí hay una muy cerca de pregunta - How to invoke async operation as sync? - pero tengo que esperar en múltiples asíncrono operaciones.

Answer 1

Para esto utiliza AutoResetEvent.

Pruebe lo siguiente por sus dos últimas líneas:

var waitEvent = new AutoResetEvent(false); 

foreach (var item in list) 
    InvokeAsync(item, url, response => { lock(lockObj) newList.Add(response); waitEvent.Set(); }); 

while (newList.Count < list.Count) 
    waitEvent.WaitOne(); 

Todos los artículos deben ser completado cuando newList contiene tantos elementos como list. Cuando entra un nuevo artículo, lo agrega al newList. Luego, indica al waitEvent que "algo" le pasó al newList.

En el hilo principal, sólo tiene que esperar hasta que haya suficientes elementos de newList y esperar a que este esperando por cambios a newList, que le informa de waitEvent.

Answer 2

De acuerdo con el protocolo HTTP, un cliente solo puede abrir 2 conexiones a un servicio.