Discussion :

[topolino]

Bonjour,

J'utilise les sockets afin de recuperer en flux continue des informations. Je dois faire des traitements dessus, commme j'ai pl'impression que c'est multi theadé mes traitements echoue.
J'utilise

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
 
client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(ReceiveCallback), state);

Comment puis je faire que que ce soit dans un seul thread.

Merci de vos conseils, je maitrise mal le sujet

[Ukualai]

Ce que l'on peut voire c'est que tu utilise une fonction asynchrone donc effectivement cela sous entend des threads. Mais tu ne donne aucun détail sur les traitements que tu dois faire...

Par exemple si tu dois mettre un jour ton interface graphique tu ne pourra pas, car tu ne te trouvera pas dans le "thread principale" dans la méthode "ReceiveCallback".
Or seul le "thread principal" est habilité à modifier les éléments graphique.

[topolino]

Comme je recois en flux continue des données, alors il est difficile de traiter de facon separer tout ce que le reseau m'envoie.
Je dois faire pas mal de traitement sur state.sb , mais avant que je puisse terminer mon traitement state.sb a deja ete modifié

Comment dois je proceder

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
 
private static void ReceiveCallback( IAsyncResult ar ) {
    try {
        // Retrieve the state object and the client socket 
        // from the asynchronous state object.
        StateObject state = (StateObject) ar.AsyncState;
        Socket client = state.workSocket;
        // Read data from the remote device.
        int bytesRead = client.EndReceive(ar);
        if (bytesRead > 0) {
            // There might be more data, so store the data received so far.
            state.sb.Append(Encoding.ASCII.GetString(state.buffer,0,bytesRead));
                //  Get the rest of the data.
            client.BeginReceive(state.buffer,0,StateObject.BufferSize,0,
                new AsyncCallback(ReceiveCallback), state);
 
/////traitement
            receiveDone.Set();
        }
    } catch (Exception e) {
        Console.WriteLine(e.ToString());
    }
}

[Ukualai]

Une première chose à faire déjà, c'est de faire tes traitements avant d'appeler à nouveau la méthode "BeginReceive".
Car dans ce que je vois de ton code, c'est que tu te remet en écoute de ton flux avant d’effectuer tes traitements, il est donc normal que ton objet "state.sb" change.

Après il reste les mécanismes de synchronisation des threads tel qu'un SyncLock (http://msdn.microsoft.com/fr-fr/library/3a86s51t.aspx)