Пытаюсь выполнить вычисления с большим количеством матриц, хочу распараллелить вычисления на 4 потока, для чего делаю следующее:
static void Main(string[] args)
{
bw1.DoWork += Bw1_DoWork;
bw2.DoWork += Bw2_DoWork;
bw3.DoWork += Bw3_DoWork;
bw4.DoWork += Bw4_DoWork;
bw1.RunWorkerCompleted += Bw1_RunWorkerCompleted;
bw2.RunWorkerCompleted += Bw2_RunWorkerCompleted;
bw3.RunWorkerCompleted += Bw3_RunWorkerCompleted;
bw4.RunWorkerCompleted += Bw4_RunWorkerCompleted;
bw1.RunWorkerAsync();
bw2.RunWorkerAsync();
bw3.RunWorkerAsync();
bw4.RunWorkerAsync();
while (g!=4)
{
Thread.Sleep(10);
}
result = summ(summ(a1,a2),summ(a3,a4));
/*вывод результата*/
}
private static int g = 0;
private static int[,] result = new int[indSize, perSize];
private static void Bw4_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
g++;
}
private static void Bw3_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
g++;
}
private static void Bw2_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
g++;
}
private static void Bw1_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
g++;
}
private static void Bw4_DoWork(object sender, DoWorkEventArgs e)
{
partialCounta4(0, (int)Math.Pow(2, n * n) / 4);
}
private static void Bw3_DoWork(object sender, DoWorkEventArgs e)
{
partialCounta3((int)Math.Pow(2, n * n) / 4, (int)Math.Pow(2, n * n) / 2);
}
private static void Bw2_DoWork(object sender, DoWorkEventArgs e)
{
partialCounta2((int)Math.Pow(2, n * n) / 2, 3 * (int)Math.Pow(2, n * n) / 4);
}
private static void Bw1_DoWork(object sender, DoWorkEventArgs e)
{
partialCounta1(3 * (int)Math.Pow(2, n * n) / 4, (int)Math.Pow(2, n * n));
}
private static int[,] a1 = new int[indSize,perSize];
private static int[,] a2 = new int[indSize, perSize];
private static int[,] a3 = new int[indSize, perSize];
private static int[,] a4 = new int[indSize, perSize];
private static BackgroundWorker bw1 = new BackgroundWorker();
private static BackgroundWorker bw2 = new BackgroundWorker();
private static BackgroundWorker bw3 = new BackgroundWorker();
private static BackgroundWorker bw4 = new BackgroundWorker();
Проблема состоит в том, что при каждом запуске получаются разные результаты, хотя вычисление конечного результата result
вроде бы должно происходить после завершения всех потоков. while g!=4
костыль, для того чтобы совершить действие после завершения всех четырех потоков. Как сделать чтобы потоки работали верно?