Come gestire il pacchetto send/ack

Question

Sto costruendo un'applicazione per comunicare con un modulo Xbee tramite l'API Xbee.

Attualmente ho qualcosa di funzionante, ma è abbastanza semplice e ha alcune limitazioni.

Sub processPackets() ' this runs as its own thread 
'remove data from serial buffer and format in to packet 
'if IO response generated remotely, not requested put in IOQueue 
'Otherwise put in CMDQueue (response generate from request, ie cmd response or packet Ack 
End Sub 

Poi, come un esempio di una richiesta di comando tipica Invia i dati alla porta seriale Loop (con timeout) controllando CMDQueue per pacchetto, dequeue e verificare se corrisponde Altrimenti timeout

Ora il suo abbastanza evidente i potenziali problemi con questo metodo. In particolare, poiché i moduli Xbee possono dormire, potrebbe essere necessario attendere molto tempo per un Ack. Inoltre dipende dall'ordine, ecc.

Mi piacerebbe adottare un approccio non bloccante. In questo caso, per agire sul pacchetto Ack/response nella maggior parte dei casi ho bisogno di sapere il pacchetto originale a cui è stato inviato in risposta.

Sto pensando di creare alcuni thread. SendPacket invierà il pacchetto, caricherà il pacchetto inviato, l'ora inviata e il timeout in memoria, includerà anche la funzione di richiamata? (array?) PacketProc analizza i pacchetti, controlla la matrice di pacchetti in attesa di risposta e chiama la funzione di callback. Verificherà anche eventuali pacchetti di attesa scaduti e richiamerà la richiamata per indicare il timeout?

In definitiva, sto cercando la capacità di inviare pacchetti a più dispositivi (può rispondere in qualsiasi ordine) e agire su quelle risposte o agire sul timeout.

Non ho particolare familiarità con .NET qualcuno può commentare questo approccio o consigliare un modello migliore per cercare? Qualunque metodo .Net dovrei cercare?

Answer 1

Utilizzare la classe Attività.

Imports System.Threading 
Imports System.Threading.Tasks 

... 
Dim buffer As StringBuilder; 
Sub processPackets() ' this runs as its own thread 
    ' Wait for packet 
    ' put here command/loop that waits packet 

    buffer.Append(packet); 
    'remove data from serial buffer and format in to packet 
    'if IO response generated remotely, not requested put in IOQueue 
    If buffer.ToString() = "REMOTELY" Then 
     ' Put IOQueuo 
     buffer.Clear() 
    Else 
     'Otherwise put in CMDQueue (response generate from request, ie cmd response or packet Ack 
     ' Put in CMDQueue 
     buffer.Clear() 
    End If 
End Sub 

...

' Create and execute the Task that will process the packets 
Dim t = Task.Factory.StartNew(Sub() processPackets()) 

http://www.dotnetcurry.com/ShowArticle.aspx?ID=491