Работа с двумя потоками boost::thread

@mat_for_c · Регистрация: 26.04.2013

Студворк — интернет-сервис помощи студентам

Есть следующий рабочий код:

C++
1
2
3
4
5
6
7
8
9
while (...) {
   ...
   th_end = ptr + (size_level - ptr)/2; //разбил на 2 половинки. конец одной есть начало другой.
   boost::thread t(par_func, ptr, th_end, priz);
   t.join();
 
   par_func(th_end, size_level, priz);
   ...
}

Однако, если сделать это через 2 отдельных потока, а именно:

C++
1
2
3
4
5
6
7
8
9
10
11
while (...) {
   ...
   th_end = ptr + (size_level - ptr)/2; //разбил на 2 половинки. конец одной есть начало другой.
   boost::thread t(par_func, ptr, th_end, priz);
   boost::thread t2(par_func, th_end, size_level, priz);
   t.join();
   t2.join();
 
   //par_func(th_end, size_level, priz);
   ...
}

то программа вылетает с ошибкой выхода за границу вектора. В чем может быть проблема?

@Crast · 09.06.2014, 10:43

Без полного кода не понятно, что вообще происходит. Но у вас есть серьезное алгоритмическое отличие.
Вторая функция par_func в первом случае выполняется после завершения потока, а во втором случае параллельно.

@mat_for_c · 09.06.2014, 14:29 **[ТС]**

Вот сама функция. Все переменные, которые используются в ней определил глобально (кроме частных переменных). При записи в общие переменные использую мьютексы.

Кликните здесь для просмотра всего текста

C++
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
void par_func (size_t beg, size_t end, vector<vector<int>>& priz) {
 
   vector<double> Expr;
   vector<int> DatW,
               DatnW;
 
   size_t i, j, k;
   int SumW, SumnW;
 
   double curBetta, curDelta;
 
   for (i = beg; i < end; ++i) {            
      Expr = Sets[level].Expr[i];
    
      if (Expr[curFeature] == Inf)
         Expr[curFeature] = curValue;
      else
         continue;  
            
      for (j = 0; j < rangA_size; ++j) {
         if (rangA[j] < cur_rang && flagTestA[j]) {
            if (isparentson(Expr, A[j]) == 2) {
               break;
            }
         }
      }
 
      if (j != rangLZK_size)
         continue;
 
      DatW= Sets[level].DatW[i];
      DatnW= Sets[level].DatnW[i];
            
      DatW.erase(set_intersection(DatW.begin(), DatW.end(), ZW_iter_b, ZW_iter_e, DatW.begin()), DatW.end());
      DatnW.erase(set_intersection(DatnW.begin(), DatnW.end(), ZnW_iter_b, ZnW_iter_e, DatnW.begin()), DatnW.end());
 
      _sizeW = DatW.size(); 
      _sizenW = DatnW.size();
 
      for(SumW = k = 0; k < _sizeW; ++k)
         SumW += weightW[DatW[k]];
        
      for(SumnW = k = 0; k < _sizenW; ++k)          
         SumnW += weightnW[DatnW[k]];
 
      if (SumW >= Nsw && (SumW+SumnW) >= r) {
    
         if (SumW == 0 && SumnW == 0)
            curDelta = NaN;
         else 
            curDelta = (double) SumW/(SumW + SumnW);
 
         curBetta = (double) SumnW / Nnw;
 
         if (curDelta >= delta && curBetta <= betta) {  
            Expr.pop_back();                
            push_A.lock();
            A.push_back(Expr);
 
            rangA.push_back(cur_rang);
            flagTestA.push_back(false);
            push_A.unlock();
 
            m_write.lock();
            outFile.open("out_inv.txt", std::ofstream::app | std::ofstream::binary);
            outFile << "<----- Number " << ++count_A << " ----->" << endl;
            outFile << endl << "Expr" << endl;
 
            for (j = 0; j < col_count; ++j)
               if (Expr[j] < Inf)
                  outFile << j+1 << " " << priz[j][(size_t)Expr[j]-1] << endl;
 
            outFile << endl << "R = " << SumW + SumnW << endl;
            outFile << endl << "delta = " << (double)SumW/(SumW + SumnW) << endl;
            outFile << endl << "sigma = " << (double)SumW/Nw << endl;
            outFile << endl << "betta = " << (double)SumnW/Nnw << endl;
            outFile << endl;
            outFile.close();
            m_write.unlock();
         }
         else {
            if ( cur_rang < rang ) {
               push_level.lock();
                    
               t_Expr.push_back(Expr);
               t_DatW.push_back(DatW);
               t_DatnW.push_back(DatnW);
                    
               push_level.unlock();
            }
         }
      }
   }
}

По структуре вроде бы все должно быть нормально. Не понимаю, почему может вылетать.

Добавлено через 1 минуту

Сообщение от Crast

Вторая функция par_func в первом случае выполняется после завершения потока

Кстати, если написать

C++
1
2
3
4
...
par_func(th_end, size_level, priz);
t.join();
...

то тоже вылетит.

Добавлено через 59 минут
Все, спасибо, разобрался. Ошибка закралась в том, что _sizeW и _sizenW я определили как глобальные переменные.

Новые блоги и статьи Все статьи Все блоги /
Подключение Box2D v3 к SDL3 для Android: физика и отрисовка коллайдеров 8Observer8 29.01.2026 Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами. Версия v3 была полностью переписана на Си, в. . .	Инструменты COM: Сохранение данный из VARIANT в файл и загрузка из файла в VARIANT bedvit 28.01.2026 Сохранение базовых типов COM и массивов (одномерных или двухмерных) любой вложенности (деревья) в файл, с возможностью выбора алгоритмов сжатия и шифрования. Часть библиотеки BedvitCOM Использованы. . .	Загрузка PNG с альфа-каналом на SDL3 для Android: с помощью SDL_LoadPNG (без SDL3_image) 8Observer8 28.01.2026 Содержание блога SDL3 имеет собственные средства для загрузки и отображения PNG-файлов с альфа-каналом и базовой работы с ними. В этой инструкции используется функция SDL_LoadPNG(), которая. . .	Загрузка PNG с альфа-каналом на SDL3 для Android: с помощью SDL3_image 8Observer8 27.01.2026 Содержание блога SDL3_image - это библиотека для загрузки и работы с изображениями. Эта пошаговая инструкция покажет, как загрузить и вывести на экран смартфона картинку с альфа-каналом, то есть с. . .
Влияние грибов на сукцессию anaschu 26.01.2026 Бифуркационные изменения массы гриба происходят тогда, когда мы уменьшаем массу компоста в 10 раз, а скорость прироста биомассы уменьшаем в три раза. Скорость прироста биомассы может уменьшаться за. . .	Воспроизведение звукового файла с помощью SDL3_mixer при касании экрана Android 8Observer8 26.01.2026 Содержание блога SDL3_mixer - это библиотека я для воспроизведения аудио. В отличие от инструкции по добавлению текста код по проигрыванию звука уже содержится в шаблоне примера. Нужно только. . .	Установка Android SDK, NDK, JDK, CMake и т.д. 8Observer8 25.01.2026 Содержание блога Перейдите по ссылке: https:/ / developer. android. com/ studio и в самом низу страницы кликните по архиву "commandlinetools-win-xxxxxx_latest. zip" Извлеките архив и вы увидите. . .	Вывод текста со шрифтом TTF на Android с помощью библиотеки SDL3_ttf 8Observer8 25.01.2026 Содержание блога Если у вас не установлены Android SDK, NDK, JDK, и т. д. то сделайте это по следующей инструкции: Установка Android SDK, NDK, JDK, CMake и т. д. Сборка примера Скачайте. . .

@Crast 72 / 72 / 5 Регистрация: 10.02.2013 Сообщений: 434
	09.06.2014, 10:43
	Без полного кода не понятно, что вообще происходит. Но у вас есть серьезное алгоритмическое отличие. Вторая функция par_func в первом случае выполняется после завершения потока, а во втором случае параллельно. 0