Есть проект программы которая сортирует большие списки строк, хотел его заставить заработать принципиально в многопоточном режиме (через Parallel не интересуют только через thred) но метод не запускается нормально и потоки странно работают, похоже что потоки не ожидают завершения друг друга или что то другое , не могу найти причину, подскажите в чем проблема тут? номера строк в метод: MyAction передаются через внешние переменные, блокировка в методе при сохранении и подсчете гудов тоже используется.Хотелось бы посмотреть ваши вариfнты на основе моего кода выше, как правильнее это реализовать через thred.
int potoky = 20;//количество потоков
Thread[] threadArrayD = new Thread[potoky];
DelimNumData = numbData;//тут общее количество строк который делится на количество потоков
for (int q = 0; q < potoky; q++)
{
for (int l = 0; l < (DelimNumData / potoky); l++)
{
rest = (q * ((DelimNumData / potoky)) + l).ToString();
}
}
dostroky = Convert.ToInt32(rest);
for (int g = 0; g < potoky; g++)
{
threadArrayD[g] = new Thread(new ThreadStart(MyAction));//Запуск метода в отдельных потоках
threadArrayD[g].IsBackground = true;
threadArrayD[g].Name = g.ToString();
threadArrayD[g].Start();
threads.Add(threadArrayD[g]);
Thread.Sleep(100);
}
foreach (Thread thred in threads)
{
thred.Join();
}
Вот лог работы потоков:
[ThreadName]: 0[FULL_numdata]: 1566 [OT]: 0[DO]: 155[ITERASIYA]: 0
[ThreadName]: 1[FULL_numdata]: 1566 [OT]: 155[DO]: 311[ITERASIYA]: 155
[ThreadName]: 2[FULL_numdata]: 1566 [OT]: 311[DO]: 467[ITERASIYA]: 311
[ThreadName]: 3[FULL_numdata]: 1566 [OT]: 467[DO]: 623[ITERASIYA]: 467
[ThreadName]: 4[FULL_numdata]: 1566 [OT]: 623[DO]: 779[ITERASIYA]: 623
[ThreadName]: 5[FULL_numdata]: 1566 [OT]: 779[DO]: 935[ITERASIYA]: 779
[ThreadName]: 6[FULL_numdata]: 1566 [OT]: 935[DO]: 1091[ITERASIYA]: 935
[ThreadName]: 7[FULL_numdata]: 1566 [OT]: 1091[DO]: 1247[ITERASIYA]: 1091
[ThreadName]: 8[FULL_numdata]: 1566 [OT]: 1247[DO]: 1403[ITERASIYA]: 1247
[ThreadName]: 9[FULL_numdata]: 1566 [OT]: 1403[DO]: 1559[ITERASIYA]: 1403
//тут ниже ошибка связанное с делением это не имеет значение тут важно почему потоки работают без конечно и без ожиданий (метод запускается и сразу завершается без обработки строк)
[ThreadName]: 9[FULL_numdata]: 1566 [OT]: 1559[DO]: 1559[ITERASIYA]: 1
[ThreadName]: 9[FULL_numdata]: 1566 [OT]: 1559[DO]: 1559[ITERASIYA]: 156
[ThreadName]: 9[FULL_numdata]: 1566 [OT]: 1559[DO]: 1559[ITERASIYA]: 157
[ThreadName]: 9[FULL_numdata]: 1566 [OT]: 1559[DO]: 1559[ITERASIYA]: 624
[ThreadName]: 9[FULL_numdata]: 1566 [OT]: 1559[DO]: 1559[ITERASIYA]: 158
[ThreadName]: 9[FULL_numdata]: 1566 [OT]: 1559[DO]: 1559[ITERASIYA]: 1248
[ThreadName]: 9[FULL_numdata]: 1566 [OT]: 1559[DO]: 1559[ITERASIYA]: 1404
numbers.AsParallel().Sort()
.потоки не ожидают завершения друг друга
в вашем коде нет ожидания завершения потоков.потоки странно работают
- метод, что вы в них отправляете, вы не показали.подскажите в чем проблема тут
- этоthreadArrayD[g]
вызовится q раз. То есть каждый элемент в массиве threadArrayD перезапишется q раз. В купе с тем, что вы не ждете конца потока, странно, что ваш код вообще как то работает - вы просто создаете портянку потоков (potoky*potoky), про бОльшую часть из них вы вовсе забываете, про остальную просто не ждете.AsParallel
MyAction
- используются ли в нем разделяемые ресурсы (что требует блокировки)? Непонятно, как у вас передается в этот метод информация о номерах строк, которые он должен обрабатывать: через внешние переменныеotstroky/dostroky
(ужас)? И т. д.MyAction
, | Нельзя использовать передачу параметров в потоки так, как вы делаете сейчас: через внешние переменныеotstroky/dostroky
. Представьте: запустили один поток со значениями 1 и 10, он начал работу; потом запустился другой поток со значениями 11 и 20 - эти же самые значения теперь использует и первый поток, потому что переменные те же самые.