Multithread et dataset

Version imprimable

Bonjour,

J'essai de faire un operation multithreads pour accelerer mes opérations dans un environnement non bloquante.

Lors de l'ouverture du formulaire je créer un dataset avec une table "Echantillon", ensuite je démarre plusieurs thread qui me permettent d'analyser mon échantillon.

Le code aurait besoin d'amélioration et j'apprécierais vos suggestions

car j'ai plusieurs messages d'erreurs qui se manifestent ici et la

il y a en autre

Citation:

La collection a été modifiée*; l'opération d'énumération peut ne pas s'exécuter.

La référence d'objet n'est pas définie à une instance d'un objet.

DataTable appartient déjà à ce DataSet.

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
Private Sub DemarrerToolStripMenuItem_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles DemarrerToolStripMenuItem.Click
        For i = 0 To 5
            Dim T As New Threading.Thread(AddressOf DoTheTask)
            T.Name = "Threads#" & i.ToString
            T.Start()
        Next
    End Sub
Sub DoTheTask()
        'boucle pour modifier les critères d'analyses 
        Do Until QuSymbole.Count = 0
            Dim Symb As String = QuSymbole.Dequeue
            Dim Expression As String = "Symbole='" & Symb & "'"
            Dim FoundRow() As DataRow
            FoundRow = ODTEchantillon.Select(Expression)
            ODTDonnee = New DataTable("" & Symb & "")
            'Importation des lignes de l'expresssion
            For Each r As DataRow In FoundRow
                Try
                    If Not IsDBNull(r) Then
                        ODTDonnee.ImportRow(r)
                    End If
                Catch ex As Exception
                    'Si erreur ajoute à la queue le symb non executé
                    Console.WriteLine(Symb & " Message erreur " & ex.Message)
                    QuSymbole.Enqueue(Symb)
                End Try
            Next
            ObjDataSet.Tables.Add(ODTDonnee)
            Console.WriteLine(ObjDataSet.Tables.Count.ToString)
            Console.WriteLine("Le thread {0} execute le symbole {1} dans le datatable {2} avec {3} données dedans", Thread.CurrentThread.Name, Symb, ODTDonnee.TableName, ODTDonnee.Rows.Count.ToString)
            ODTDonnee.Clear()
            ODTDonnee = Nothing
        Loop
        Console.WriteLine(ObjDataSet.Tables.Count.ToString)
    End Sub

merci de votre aide

13/11/2011, 18h39
Pol63
le multithreading n'est pas quelque chose de forcément simple
étant que plusieurs thread peuvent accéder aux même choses en même temps ca peut causer des problèmes

le plus simple c'est i = i + 1
i est évalué, on ajoute un au résultat, et on range le résultat dans i
si 2 threads font ca exactement au même moment et que i vaut 2 avant le traitement, on devrait avoir 4 dans i
or si les 2 lisent 2 au même moment, font +1 ils vont obtenie 3 et ranger 3 dans i

autre problème rencontré souvent
un thread qui parcourt une collection
Code:

1 2 for each item in collection next
et un autre thread qui ajoute ou supprime un élément

Code:

collection.add(newitem)

et le thread qui parcourait la boucle est planté, car la collection a changé et l'énumérateur est caduque

pour éviter ces cas, il y a diverses méthodes, clone une collection, utiliser synclock, readerwriterlock ou autre
13/11/2011, 21h53
Mario Rousson

mon principal problème est que j'ai un message genre objet référence null à la ligne ODTdonnees.clear()

serait-ce une bonne idée de créer, supposons pour 10 thread, 10 dataset ex:
Dim ODTDonnees1 as new datatable
Dim ODTDonnees2 as new datatable
Dim ODTDonnees3 as new datatable
etc.

puis faire l'appel à la datatable au numéro qui correspond au thread appelant

ex:

selectcase thread.name

case thread1
ODTDonnees1....
etc.

ainsi le même thread appelerait toujours le même datatable

je soumais l'idée...
13/11/2011, 22h00
Pol63

oui mais ne pasfaire ca avec un numéro et une variable par thread mais avec un dictionary(of thread, datatable)
et un truc du genre dt = dico(threading.thread.current)

En suivant les conseils de Pol63, et utilisant la classe dictionary pour la première fois, j'ai codé ça et j'aimerais votre opinion sur ce, car dans cet état le programme ne roule pas mieux. Cela dit, je suis sur que le conseil de Pol était bon, c'est mon manque d'expérience qui fait défaut.

Alors j'ai créer un petit programme pour tester le dictionary et j'ai un message d'erreur

Citation:

La référence d'objet n'est pas définie à une instance d'un objet.

à la ligne Console.WriteLine(tf.TableName)

Code:

1
2
3
4
5
6
7
8
9
10
Sub DoTheTask()
        Dim Sq As New dictio
        Dim Th As String = Thread.CurrentThread.Name
        Sq.Create(Th, "Datata" & Th)
        Ds.Tables.Add(Sq(Th))
        For Each tf As DataTable In Ds.Tables
            Console.WriteLine(tf.TableName)
        Next
        Sq("Datata" & Th) = Nothing
    End Sub

et la class dictio est

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
Public Class dictio
    Inherits System.Collections.DictionaryBase
    Sub Add(ByVal Key As String, ByVal Str1 As DataTable)
        Dictionary.Add(Key, Str1)
    End Sub
    Function Create(ByVal Key As String, ByVal DataT As String) As DataTable
        Create = New DataTable(DataT)
        Dictionary.Add(Key, Create)
    End Function
    Default Property Item(ByVal Key As String) As DataTable
        Get
            Return CType(Dictionary.Item(Key), DataTable)
        End Get
        Set(ByVal value As DataTable)
            Dictionary.Item(Key) = value
        End Set
    End Property
End Class

merci de m'aider

!?

pourquoi recréer une classe héritante ?

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
private _dico as new collections.generic.dictionary(of threading.thread, datatable)
 
public sub demarrethreads
  for i as integer = 0 to 3
    dim dt as new datatable
    dim th as new threading.thread(addressof threadtraitement)
    _dico.add(th, dt)
  next
 
  ' démarage
  for each th as thread in _dico.keys
     th.Start 
   next
end sub
 
private sub threadtraitement
   dim dt as datatable = _dico(threading.thread.currentthread)
end sub

16/11/2011, 19h33
Mario Rousson

Merci à toi Pol 63 j'ai beaucoup appris, même si en bout de ligne je me suis rendu compte que je n'avais pas besoin d'utiliser la classe dictionairy j'ai eu l'occasion de la connaitre.

Puis je maitrise mieux le multi-thread.