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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
| using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Threading;
using System.Windows.Forms;
namespace test_BackgroundWorker
{
public partial class Form1 : Form
{
private int _indexBw = 0;
private List<object> listBw;
public Form1()
{
InitializeComponent();
}
private void Form1_Load(object sender, EventArgs e)
{
//CheckForIllegalCrossThreadCalls = false;
listBw = new List<object>();
}
private void Form1_FormClosing(object sender, FormClosingEventArgs e)
{
// faudrait une tempo plutot que de bloquer la fermeture s'il reste des "bw.IsBusy" en attendant qu'ils soient fermés ..
for (int i = 0; i < listBw.Count; i++) {
BackgroundWorker bw = listBw[i] as BackgroundWorker;
if (bw.IsBusy == true) {
(listBw[i] as BackgroundWorker).CancelAsync();
e.Cancel = true;
}
}
}
private void LancerProcessLong_Click(object sender, EventArgs e)
{
ProcessLong proc = new ProcessLong();
ProcessLong.form = this;
proc.idBw = _indexBw++;
proc.eventCreaLigne += new ProcessLong.creaLigneHandler(proc_eventCreaLigne);
proc.eventMajLigne += new ProcessLong.majLigneHandler(proc_eventMajLigne);
toolStripTextBox1.Text = _indexBw.ToString();
BackgroundWorker bw = new BackgroundWorker();
listBw.Add(bw);
bw.WorkerReportsProgress = true;
bw.WorkerSupportsCancellation = true;
bw.DoWork += new DoWorkEventHandler(proc.procDoWork);
bw.RunWorkerCompleted += new RunWorkerCompletedEventHandler(proc.procComplet);
bw.ProgressChanged += new ProgressChangedEventHandler(proc.procProgressChange);
bw.RunWorkerAsync();
}
private void AnnulerPremier_Click(object sender, EventArgs e)
{
for (int i = 0; i < listBw.Count; i++) {
BackgroundWorker bw = listBw[i] as BackgroundWorker;
if (bw.IsBusy == true) {
(listBw[i] as BackgroundWorker).CancelAsync();
break;
}
}
}
private void AnnulerDernier_Click(object sender, EventArgs e)
{
(listBw[(listBw.Count - 1)] as BackgroundWorker).CancelAsync();
for (int i = listBw.Count - 1; i >= 0; i--) {
BackgroundWorker bw = listBw[i] as BackgroundWorker;
if (bw.IsBusy == true) {
(listBw[i] as BackgroundWorker).CancelAsync();
break;
}
}
}
private void StopperTout_Click(object sender, EventArgs e)
{
for (int i = 0; i < listBw.Count; i++) {
BackgroundWorker bw = listBw[i] as BackgroundWorker;
if (bw.IsBusy == true) {
(listBw[i] as BackgroundWorker).CancelAsync();
}
}
}
private void proc_eventMajLigne(object sender, int indexLigne, object chaine)
{
dataGridView1[0, indexLigne].Value = chaine;
}
private int proc_eventCreaLigne(object sender, object chaine)
{
return dataGridView1.Rows.Add(chaine);
}
}
public class ProcessLong
{
public delegate int creaLigneHandler(object sender, object chaine);
public delegate void majLigneHandler(object sender, int indexLigne, object chaine);
public event creaLigneHandler eventCreaLigne;
public event majLigneHandler eventMajLigne;
// valeur a incrémenter
private int _valeur = 0;
// ID BackgroundWorker
private int _idBw;
public int idBw { get { return _idBw; } set { _idBw = value; } }
// formulaire parent -> obliger d'utiliser une référence pour y accéder ?
private static Form1 _form;
public static Form1 form { get { return _form; } set { _form = value; } }
// index DataGrid pour ce BackgroundWorker
private int _indexDtg;
public int indexDtg { get { return _indexDtg; } set { _indexDtg = value; } }
public void procDoWork(object sender, DoWorkEventArgs e)
{
//Console.WriteLine("work debut{0} : {1}", this._idBw, this._valeur);
_indexDtg = this.eventCreaLigne(this, "work debut(" + _idBw.ToString() + ") : " + _valeur.ToString());
BackgroundWorker worker = sender as BackgroundWorker;
while (worker.CancellationPending == false && _valeur < 5000) {
Thread.Sleep(1);
worker.ReportProgress(_valeur);
_valeur++;
}
}
public void procComplet(object sender, RunWorkerCompletedEventArgs e)
{
if (e.Error != null) {
//Console.WriteLine("work ERREUR{0} : {1}", this._idBw, this._valeur);
this.eventMajLigne(this, _indexDtg, "work ERREUR(" + _idBw.ToString() + ") : " + _valeur.ToString());
}
else if (e.Cancelled == true) {
//Console.WriteLine("work ANNULÉ{0} : {1}", this._idBw, this._valeur);
this.eventMajLigne(this, _indexDtg, "work ANNULÉ(" + _idBw.ToString() + ") : " + _valeur.ToString());
}
else {
//Console.WriteLine("work fini{0} : {1}", this._idBw, this._valeur);
this.eventMajLigne(this, _indexDtg, "work FINI(" + _idBw.ToString() + ") : " + _valeur.ToString());
}
}
public void procProgressChange(object sender, ProgressChangedEventArgs e){
//Console.WriteLine("work en cours{0} : {1}", this._idBw, this._valeur);
this.eventMajLigne(this, _indexDtg, "work en cours(" + _idBw.ToString() + ") : " + _valeur.ToString());
}
}
} |
