Coroutine in C#

Question

Sto cercando modi per implementare le co-routine (thread pianificati dall'utente) in C#. Usando il C++ stavo usando le fibre. Vedo su internet le fibre non esistono in C#. Mi piacerebbe avere una funzionalità simile.

Esiste un modo "giusto" per implementare le coroutine in C#?

Ho pensato di implementare questo utilizzando thread che acquisiscono un singolo mutex di esecuzione + 1 sul thread dello scheduler che rilascia questo mutex per ogni coroutine. Ma questo sembra molto costoso (forza un cambio di contesto tra ogni coroutine)

Ho anche visto la funzionalità di iteratore di rendimento, ma come ho capito non puoi cedere all'interno di una funzione interna (solo nella funzione di ienumerator originale). Quindi questo mi fa poco bene.

Answer 1

Edit: È ora possibile utilizzare questi: Is there a fiber api in .net?

Credo che si dovrebbe guardare la la Reactive Extensions for .NET. Ad esempio, dichiarazione coroutines can be simulated using iterators and the yield.

Tuttavia si consiglia di leggere anche questo SO question.

Answer 2

Here è un esempio di utilizzo di thread per implementare coroutine:

Così ho barare. Io uso thread, ma io solo lasciare che uno di loro venga eseguito alla volta. Quando io creo un coroutine, creo un filo, e poi fare un po 'strette di mano che termina con una chiamata a Monitor.Wait(), che blocca il filo coroutine - non funzionerà più fino a quando è sbloccato. Quando è il momento di chiamare la coroutine, eseguo un trasferimento che termina con il thread di chiamata bloccato e il thread di coroutine eseguibile. Stesso tipo di trasferimento al ritorno.

Questi handoff sono costosi, rispetto ad altre implementazioni. Se hai bisogno di velocità, ti consigliamo di scrivere il tuo computer di stato , e evitare tutto questo cambio di contesto. (Oppure si vorrà utilizzare un runtime in fibra ottica - le fibre di commutazione sono piuttosto economiche .) Ma se si desidera il codice espressivo , penso che le coroutine contengano qualche promessa .

Answer 3

Credo che con il nuovo .NET 4.5 \ C# 5 il modello asincrono/atteso dovrebbe soddisfare le vostre esigenze.

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

Suggerisco di guardare http://channel9.msdn.com/Events/TechEd/Australia/Tech-Ed-Australia-2011/DEV411 per ulteriori informazioni. È una grande presentazione.

Anche http://msdn.microsoft.com/en-us/vstudio/gg316360 ha alcune grandi informazioni.

Se si utilizza una versione precedente di .NET, è disponibile un CTP Async per .NET precedente con licenza go live in modo da poterlo utilizzare negli ambienti di produzione.Ecco un collegamento al CTP http://www.microsoft.com/download/en/details.aspx?displaylang=en&id=9983

Se non ti piace nessuna delle opzioni di cui sopra, credo che potresti seguire lo schema iteratore asincrono come descritto qui. http://www.microsoft.com/download/en/details.aspx?displaylang=en&id=9983

Answer 4

this è una libreria che nasconde l'utilizzo di coroutine. Ad esempio, per leggere un file:

//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(); 

Questa libreria utilizza un thread per eseguire tutti coroutine e permettere di richiamare il compito per le operazioni asincrone veramente. Ad esempio, per chiamare un altro metodo come un coroutine (aka cedendo per il suo ritorno

//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;