Std::thread. Нет ожидаемого поведения при независимом вычислении элементов вектора

@Lyosha12 · Регистрация: 02.04.2016

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

Хочу распараллелить вычисления отдельных элементов массива: каждый - в своём потоке.

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

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
#include <iostream>
#include <iomanip>
#include <vector>
#include <thread>
#include <atomic>
using namespace std;
 
template <class T>
ostream& operator<< (ostream& out, vector<T> const& v) {
    for(auto const& x: v)
        out << setw(5) << x << ' ';
    return out;
}
 
void f(int& x, atomic<size_t>& count_results, size_t i) {
    for(size_t j = 0; j <= i; ++j)
        x = x + 1;
    ++count_results;
}
 
void g() {
    vector<int> v(10, 0);
    
    atomic<size_t> count_results = 0;
    for(size_t i = 0; i != 10; ++i)
        thread(f, ref(v[i]), ref(count_results), i).detach();
    
    while(count_results != 10)
        this_thread::yield();
    
    cout << v << endl;
}
 
int main() {
    
    for(size_t k = 1; k <= 100; ++k) {
        cout << "Step " << setw(3) << k << ": ";
        g();
    }
    
    return 0;
}

Проблема в том, что, как мне кажется, не всякий раз поток можно запустить.
Когда я говорю detach(), то в какой-то проход хотя бы один из потоков не запустится,
из-за чего главный поток всё время будет ожидать увеличения счётчика количества выполненной работы.

Как с этим бороться? Что нужно добавить для ожидаемого поведения?

@nmcf · 04.12.2017, 23:09

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

одновременно для всех объектов?

По порядку. Зачем join() одновременно запускать?

@Lyosha12 · 04.12.2017, 23:50 **[ТС]**

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

Зачем join() одновременно запускать?

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

Какой смысл в последовательном исполнении, если операции не зависимы?

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

Я матрицы умножаю: умножение каждой строки матрицы A на матрицу B в отдельном потоке.

Как уж изъясняться, что я хочу и музыку слушать, и по улице гулять?

@nmcf · 05.12.2017, 00:00

Ты плохо понимаешь как thread работает. Сначала создаёшь потоки, они начинают работать и join() никак этому не мешает, если не делать так, как у тебя - вызов сразу от временного объекта. Ты создал, к примеру, два потока, они начали работу, а после делаешь:

C++
1
2
th1.join();
th2.join();

nd2 · 05.12.2017, 04:08

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
template <class T>
ostream& operator<< (ostream& out, const vector<T>& v) 
{
    for (const auto& x : v)
        out << x << ' ';
    return out;
}
 
void f(vector <int>& v, const size_t beg, const size_t end, const int j)
{
    for (size_t i = beg; i < end; ++i)
        v[i] += j;
}
 
int main() 
{
    vector <int> v(30, 0);
    
    vector <thread> vthr;
    
    int i = 1;
    size_t beg = 0;
    const size_t n = 10;
    size_t end = beg + n;
    for (int j = 0; j < 3; ++j)
    {
        vthr.push_back(thread(f, ref(v), beg, end, i++));
        
        beg = end;
        end += n;
    }
    
    for (auto& thr : vthr)
        thr.join();
 
    cout << v << endl;
        
    system("pause");
    return 0;
}

@GbaLog- · 05.12.2017, 07:25

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

ваша реализация библиотеки не поддерживает такого количества потоков.

когда это стандартная библиотека начала определять кол-во возможных потоков?

@Lyosha12 · 06.12.2017, 18:27 **[ТС]**

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

Ты плохо понимаешь как thread работает. Сначала создаёшь потоки, они начинают работать и join() никак этому не мешает, если не делать так, как у тебя - вызов сразу от временного объекта.

Благодарю за пояснение. Проверил - верно. Поставил Cygwin - всё работает, всё в норме.

Новые блоги и статьи Все статьи Все блоги /
FPS контроллер с анимированными Y-Bot и 3D-звуком miniaudio (Box3D, Recast, BehaviorTree.CPP, ozz-animation, ImGui, OpenGL и SDL3) 8Observer8 18.10.2026 Содержание блога \| English Version Полное мультиплатформенное руководство по стартовому проекту с FPS-контроллером игрока, анимированными роботами Y-Bot с 4-слойным блендингом, 3D-физикой Box3D,. . .	Локальный http сервер Argus19 17.10.2026 Локальный http сервер На работе, на двух локальных компьютерах круглосуточно работают программы опроса приборов с записью в книги Excel,которые раз в сутки записываются на сервер компании. Т. к. . . .	Копировать Windows на новый диск на UEFI damix 17.10.2026 https:/ / uriesk. wordpress. com/ 2016/ 11/ 01/ move-window-10-to-ssd-on-a-uefi-dualboot-system-with-basic-linux-tools/ TL DR Вставляем диск, а старый подключаем через переходник, грузимся с лайва. . .	ИИ не может найти нужный язык в списке Supersumestria 05.10.2026 Я ему даю вот такое изображение и прошу найти и подчеркнуть немецкий язык. Возвращает он вот это: https:/ / i. **********/ vqBWLe2. png Нужную строчку в 3й колонке просто выдумал. . Это. . .
Новая последняя моя музыка в SUNO zorxor 05.10.2026 Здравствуйте, дорогие мои друзья! С большой радостью я хотел бы представить вам свою новую последнею музыку, которую сгенерировала мне по моей просьбе нейросеть SUNO. С уважением, zorxor. Это. . .	Программный домашний кинотеатр russiannick 27.09.2026 Сподобился на программный домашний кинотеатр. В качестве ЯВУ по традиции выбрал js. В помощники взял Яндекс-Алису. Было создано три зала на разные интересы. исторические и ретро сериал Хичкок. . .	Беседа с ИИ о программистах, недопускающих к созданию и правке кода генеративные ИИ и причины этого zorxor 21.09.2026 Раньше я радовался или получал некоторые эмоции, пусть небольшие, но всё же, от самого процесса написания кода, рекомпиляции и запуска, видя постепенное развитие программы и прочее. А теперь лень. . .	Мобильное приложение ColorStep pavlinmavlin 17.09.2026 Реализовал приложение Красный, Зеленый, Синий в Unity3d + c#. Название изменил на ColorStep. Приложение прошло модерацию и теперь доступно для скачивания. Делал его сам, шаг за шагом — и вот,. . .

Std::thread. Нет ожидаемого поведения при независимом вычислении элементов вектора

Решение