API asynchrones pour diffusion de données en streaming d'un périphérique matériel

Il y a quelques façons d'aller avec cela. Dans la plupart des langues, vous pouvez faire des appels ASYNC à des méthodes à l'aide de threads ou de répartiteurs. En général, tant que vous faites votre dll ré-entrant (capable d'entretenir Plusieurs threads en même temps) L'environnement appelant peut prendre soin de la partie ASYNC.

Il est possible de faire cuire les appels ASYNC dans votre API. Un exemple de quelque chose qui fait ceci est le proxy client WCF .

Microsoft a un bon article sur cette question. Si vous venez de déménager sur l'endinvoke, cela devrait également fonctionner pour vous. http://msdn.microsoft.com/fr- US / Bibliothèque / 2E08F6YC (v = vs.71) .aspx

• puisque vous voulez que les deux entrées et la sortie soient asynchrones, vous aurez besoin d'un Fil de travailleur: Si ni le fil d'entrée, ni celui qui prend La sortie peut être bloquée, les deux ne peuvent pas être dérangées pour faire le travail.

• Votre déjà pensé de communiquer via des tuyaux, mais pourquoi utiliser un tuyau et non une stricture interne?

• Vous avez donc cette file d'attente sans verrouillage sur l'entrée, une autre sur la sortie et un thread de travailleur

• Le thread du travailleur prend la saisie de l'inquée, le traite, le met dans l'Outquue

• Si la file d'attente d'entrée devient vide, le thread du travailleur n'a rien à reprocher, alors il soulève un événement "Besoin plus de données" puis des blocs sur la file d'attente d'entrée devenant (en partie) pleine

• Si le fil du travailleur met quelque chose dans la file d'attente de sortie, il pose un événement "avoir plus de données", et si la file d'attente de sortie devient (entièrement) pleine, il bloque l'espace de sortie devenant disponible < / li>

• Votre API est non bloquante: ni l'envoi d'une entrée ni de sortie de sortie jamais bloquée

• Votre API est async: les notifications (via des événements) sont données

Selon les commentaires de l'OP L'application d'appel envoie audio à la DLL, la DLL envoie audio via une interface USB, la DLL capture de l'audio à partir de l'interface MIC et doit renvoyer l'audio capturé à l'application alors que L'application envoie audio à la DLL, etc.

basé sur cela et le fait que l'appel peut être écrit dans Rahter différentes langues, je vois des options pour les canaux de communication:

• TCP / IP (en fonction de "Paramètres de pare-feu de bureau", etc. Cela pourrait être problématique!)
• Tuyaux
• COMBES COM avec des manipulateurs d'événements / d'événements
• DLL avec rappel, bien que cela soit un peu difficile de travailler pour toutes les langues
• Mémoire partagée avec des mutiles globales (pourrait faciliter cela pour la demande de consommation en proposant une fonction "Configuration" de la DLL qui renvoie les noms-points et les noms mutex)

J'aime l'approche suivante car cela rend vraiment simple pour les clients.

// your library
class Foo {
   public event EventHandler ComputeCompleted = (sender, e) => { };

   public void Compute() {
      // kick off work on a background thread
      // possibly using the BackgroundWorker object
      var bw = new BackgroundWorker();      
      bw.RunWorkerCompleted += RunWorkerCompleted;
      bw.RunWorkerAsync(); 
   }

   private void RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) {
        ComputeCompleted(this, new object()); 
   }
}

// calling code
Foo foo = new Foo();
foo.ComputeCompleted += Completed;
foo.Compute();

private void Completed(object Sender, EventArgs e) {
   // process the result here
}