Corutinas en C#

Question

Estoy buscando formas de implementar co-rutinas (hilos programados por el usuario) en C#. Cuando usé C++, estaba usando fibras. Veo en Internet que las fibras no existen en C#. Me gustaría obtener una funcionalidad similar.

¿Hay alguna forma "correcta" de implementar corutinas en C#?

He pensado en implementar esto utilizando subprocesos que adquieren una sola ejecución mutex + 1 en el hilo del planificador que libera este mutex para cada corrutina. Pero esto parece muy costoso (fuerza un cambio de contexto entre cada corrutina)

También he visto la funcionalidad del iterador de rendimiento, pero según tengo entendido, no puede ceder dentro de una función interna (solo en la función ienumerator original). Entonces esto me hace poco bien.

Answer 1

Editar: puede ahora utilizar estos: Is there a fiber api in .net?

Creo que usted debe buscar en el la Reactive Extensions for .NET. Por ejemplo, la declaración coroutines can be simulated using iterators and the yield.

Sin embargo, es posible que desee leer este SO question también.

Answer 2

Here es un ejemplo de la utilización de hilos de implementar co-rutinas:

Así hago trampa. Yo uso hilos, pero solo dejo que uno de ellos se ejecute a la vez. Cuando crear una co-rutina, se crea un hilo, y luego hacer un poco de toma de contacto que termina con una llamada a Monitor.Wait(), que bloquea el hilo corrutina - no se ejecutará más hasta que sea desbloqueado. Cuando es hora de llamar a coroutine, hago un traspaso que finaliza con el llamada de subproceso bloqueado, y el subproceso de corrutina ejecutable. Mismo tipo de handoff en el camino de regreso.

Esas entregas son un poco caras, en comparación con otras implementaciones. Si necesita velocidad, querrá escribir su propia máquina de estados y evitar todo este cambio de contexto. (O querrá utilizar un tiempo de ejecución sensible a la fibra - el cambio de las fibras es bastante barato.) Pero si quiere el código expresivo , creo que las coroutines tienen alguna promesa de .

Answer 3

Creo que con el nuevo .NET 4.5 \ C# 5 el patrón async \ await debería satisfacer sus necesidades.

async Task<string> DownloadDocument(Uri uri) 
{ 
    var webClient = new WebClient(); 
    var doc = await webClient.DownloadStringTaskAsync(url); 
    // do some more async work 
    return doc; 
} 

Sugiero mirar http://channel9.msdn.com/Events/TechEd/Australia/Tech-Ed-Australia-2011/DEV411 para obtener más información. Es una gran presentación.

También http://msdn.microsoft.com/en-us/vstudio/gg316360 tiene mucha información.

Si está utilizando una versión anterior de .NET, hay un CTP Async disponible para .NET más antiguo con una licencia de activación para que pueda usarlo en entornos de producción.Aquí hay un enlace al CTP http://www.microsoft.com/download/en/details.aspx?displaylang=en&id=9983

Si no le gusta ninguna de las opciones anteriores, creo que podría seguir el patrón de iterador asíncrono como se describe aquí. http://www.microsoft.com/download/en/details.aspx?displaylang=en&id=9983

Answer 4

Te puede interesar this es una biblioteca que oculta el uso de corutinas. Por ejemplo, para leer un archivo:

//Prepare the file stream 
FileStream sourceStream = File.Open("myFile.bin", FileMode.OpenOrCreate); 
sourceStream.Seek(0, SeekOrigin.End); 

//Invoke the task 
yield return InvokeTaskAndWait(sourceStream.WriteAsync(result, 0, result.Length)); 

//Close the stream 
sourceStream.Close(); 

Esta biblioteca utiliza un hilo para ejecutar todas corrutinas y permitir llamar a la tarea para las operaciones verdaderamente asíncronos. Por ejemplo, para llamar a otro método como una co-rutina (también conocido como rendimiento para su retorno

//Given the signature 
//IEnumerable<string> ReadText(string path); 

var result = new Container(); 
yield return InvokeLocalAndWait(() => _globalPathProvider.ReadText(path), container); 
var data = container.RawData as string;