¿Cuál es el equivalente de C# de MsgWaitForMultipleObjects?

Question

Tengo un formulario de Windows con un ListView en modo de informe. Para cada elemento en la vista, necesito realizar una operación de larga ejecución, cuyo resultado es un número.

La forma en que haría esto en win32 nativo es crear un hilo de trabajo para cada elemento (ingenuamente, por supuesto no crearé un número ilimitado de subprocesos) y luego MsgWaitForMultipleObjects() en la matriz de manejadores de subprocesos. A medida que finaliza cada cálculo, los hilos señalan y el subproceso principal de UI se activa y se actualiza. Mientras tanto, enviamos mensajes para que el hilo de la interfaz de usuario siga siendo receptivo.

¿Alguien puede dar un ejemplo de cómo esto podría funcionar en C#? Miré el objeto Monitor, y no parece ser lo que quiero, ¿o bombea mensajes mientras bloquea?

Gracias.

Editar: Parece que WaitHandler.WaitAny() podría realmente bombear mensajes. Consulte cbrumme's treatise sobre el bombeo de mensajes en el CLR.

Answer 1

El objeto activo de larga ejecución, creo, es la mejor opción en su caso. El hilo principal llama al proxy (del objeto activo). Proxy convierte el método de llamada al mensaje y este mensaje va a una cola. Proxy devuelve al llamante el objeto futuro (es una referencia al resultado futuro). El despachador dequeues mensajes uno por uno y realmente ejecuta su tarea en otro hilo (hilo de trabajo). Cuando el hilo de trabajo completa una tarea, actualiza el resultado del objeto futuro o llama al método de devolución de llamada (por ejemplo, para actualizar su UI). El detector puede tener muchos hilos de trabajo para ejecutar más una tarea al mismo tiempo.

Puede ver esto article (con muestra) sobre el patrón de objeto activo de larga ejecución.

Answer 2

Haga que su hilo principal cree una secuencia de administrador. Puede usar el BackgroundWorker para esto. Este hilo de administrador inicia un hilo de trabajo para cada elemento en el ListView. Esto permitirá que su UI siga respondiendo a la entrada del usuario sin colgar mientras se procesan los hilos de fondo.

Ahora, el problema es cómo esperar a que termine cada subproceso de trabajo. Lamentablemente, no he podido encontrar la forma de obtener un identificador de subproceso para objetos System.Threading.Thread. No digo que no haya una manera de hacerlo; Simplemente no he encontrado uno. Otro aspecto complicado de esto es que la clase System.Threading.Thread está sellada, por lo que no podemos derivar de ella para proporcionar algún tipo de 'manejo'.

Aquí es donde yo uso ManualResetEvent.

Digamos que cada subproceso de trabajo es simplemente un subproceso ThreadPool. La gestión BackgroundWorker crea un objeto ManualResetEvent para cada elemento en el ListView. Como el BackgroundWorker lanza cada hilo ThreadPool, pase ManualResetEvent como argumento al QueueUserWorkItem function. Luego, justo antes de que salga cada hilo ThreadPool, configure el objeto ManualResetEvent.

El subproceso BackgroundWorker puede colocar todos los objetos ManualResetEvent en una matriz y esperar en esa matriz con WaitHandle.WaitXXX functions. A medida que finaliza cada subproceso, puede utilizar los eventos BackgroundWorker para actualizar la interfaz de usuario o puede usar la técnica Control.Invoke() para actualizar la interfaz de usuario (consulte la respuesta de Marc Gravell here).

Espero que esto ayude.