0 / 0 / 0
Регистрация: 12.10.2016
Сообщений: 11
1

Вектор потоков

23.04.2019, 08:46. Показов 2145. Ответов 0
Метки нет (Все метки)

Author24 — интернет-сервис помощи студентам
В зависимости от количества доступных системе потоков, надо использовать эти потоки. Хочу сделать это всё вектором. Вот два куска кода. В первом без вектора, просто "в лоб", всё работает, и с увеличением потоков программа ускоряется (при 2 в 1.6 раз, при 4 в 2.6 раз).
Второй кусок кода - попытка сделать через векторы. Потоки, вроде, создаются, но программа при любом их количество работает одинаково, не ускоряясь
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
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
#include <iostream>
#include <vector>
#include <ctime>
#include <thread>
#include <algorithm>
#include <Windows.h>
 
struct SLAU
{
public:
    SLAU(int n) : Size(n) //конструктор. Задает СЛАУ
    {
        System.resize(Size);
        for (auto &i : System)
        {
            i.resize(Size);
            for (auto &j : i)
            {
                j = rand() % 10;
            }
        }
    }
 
    void show_system() // Вывод исходной СЛАУ
    {
        for (const auto &i : System)
        {
            for (const auto &j : i)
            {
                std::cout << j << " ";
            }
            std::cout << std::endl;
        }
    }
 
    void show_div() //Вывод разбиения
    {
        for (const auto i : Div)
        {
            for (const auto j : i)
            {
                std::for_each(j.begin(), j.end(), [](int x){std::cout << x << " "; });
                std::cout << std::endl;
            }
            std::cout << std::endl << std::endl;
        }
    }
 
    void set_div() //Разбиваем систему на блоки по кол-ву потоков 
    {
        int k = 0;
        int count = threads;
        Div.resize(threads);
        for (auto &i : Div)
        {
            if (Size != 0)
            {
                i.resize(Size / count);
                Size -= (Size / count);
                count--;
            }
            else break;
            for (auto &j : i)
            {
                j.resize(System.size());
                std::copy(System[k].begin(), System[k].end(), j.begin());
                k++;
            }
        }
    }
 
    std::vector<std::vector<int>> get_vector(int i)
    {
        return Div[i];
    }
 
    int get_size()
    {
        return Size;
    }
 
    int get_threads()
    {
        return threads;
    }
 
private:
    int threads = 2;//std::thread::hardware_concurrency();
    int Size;
    std::vector<std::vector <int>> System;
    std::vector<std::vector<std::vector <int>>> Div;
};
 
struct ved_str
{
    //int number;
    std::vector<int> mas;
};
 
void main_string(std::vector<std::vector <int>> &vec, ved_str *str, int j, int eq_num) //поиск локальной ведущей строки
{
    int max_value = -1;
    int number = 0;
    for (int i = 0; i < vec.size(); i++)
    {
        if (j > eq_num)
        {
            eq_num++;
            continue;
        }
        else if (vec[i][j] > max_value)
        {
            max_value = vec[i][j];
            number = i;
        }
    }
    str->mas.push_back(max_value);
}
 
int main()
{
    double Time = 0;
        int size = 100;
        
        srand(time(NULL));
        SLAU s1(size);
        std::vector<std::thread> thrds;
        s1.set_div();
        ved_str Main_str;
//ПОТОКИ
        for (int j = 0; j < 10; j++) //
        {
            double start = clock();
            for (int i = 0; i < size; i++)
            {
                
                std::thread a(main_string, s1.get_vector(0), &Main_str, i, 0);
                std::thread b(main_string, s1.get_vector(1), &Main_str, i, 150);
                //std::thread c(main_string, s1.get_vector(2), &Main_str, i, 150);
                //std::thread d(main_string, s1.get_vector(3), &Main_str, i, 225);
 
                a.join();
                b.join();
                //c.join();
                //d.join();
 
                Main_str.mas.clear();
                
            }
            double end = clock();
            Time += (end - start) / 1000;
            std::cout << (end - start) / 1000 << std::endl;
        }
 
    system("pause");
    return 0;
}
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
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
#include <iostream>
#include <vector>
#include <ctime>
#include <thread>
#include <algorithm>
#include <Windows.h>
 
struct SLAU
{
public:
    SLAU(int n) : Size(n) //конструктор. Задает СЛАУ
    {
        System.resize(Size);
        for (auto &i : System)
        {
            i.resize(Size);
            for (auto &j : i)
            {
                j = rand() % 10;
            }
        }
    }
 
    void show_system() // Вывод исходной СЛАУ
    {
        for (const auto &i : System)
        {
            for (const auto &j : i)
            {
                std::cout << j << " ";
            }
            std::cout << std::endl;
        }
    }
 
    void show_div() //Вывод разбиения
    {
        for (const auto i : Div)
        {
            for (const auto j : i)
            {
                std::for_each(j.begin(), j.end(), [](int x){std::cout << x << " "; });
                std::cout << std::endl;
            }
            std::cout << std::endl << std::endl;
        }
    }
 
    void set_div() //Разбиваем систему на блоки по кол-ву потоков 
    {
        int k = 0;
        int count = threads;
        Div.resize(threads);
        for (auto &i : Div)
        {
            if (Size != 0)
            {
                i.resize(Size / count);
                Size -= (Size / count);
                count--;
            }
            else break;
            for (auto &j : i)
            {
                j.resize(System.size());
                std::copy(System[k].begin(), System[k].end(), j.begin());
                k++;
            }
        }
    }
 
    std::vector<std::vector<int>> get_vector(int i)
    {
        return Div[i];
    }
 
    int get_size()
    {
        return Size;
    }
 
    int get_threads()
    {
        return threads;
    }
 
private:
    int threads = std::thread::hardware_concurrency();
    int Size;
    std::vector<std::vector <int>> System;
    std::vector<std::vector<std::vector <int>>> Div;
};
 
struct ved_str
{
    //int number;
    std::vector<int> mas;
};
 
void main_string(std::vector<std::vector <int>> &vec, ved_str *str, int j, int eq_num) //поиск локальной ведущей строки
{
    int max_value = -1;
    int number = 0;
    for (int i = 0; i < vec.size(); i++)
    {
        if (j > eq_num)
        {
            eq_num++;
            continue;
        }
        else if (vec[i][j] > max_value)
        {
            max_value = vec[i][j];
            number = i;
        }
    }
    str->mas.push_back(max_value);
}
 
int main()
{
    double Time = 0;
        int size = 100;
        
        srand(time(NULL));
        SLAU s1(size);
        std::vector<std::thread> thrds;
        s1.set_div();
        ved_str Main_str;
        //ПОТОКИ
        double start = clock();
        for (int i = 0; i < size; i++)
        {
            int equation_number = 0;
            for (int j = 0; j < s1.get_threads(); j++)
            {
                thrds.push_back(std::thread(&main_string, s1.get_vector(j), &Main_str, i, equation_number));
                equation_number += s1.get_vector(j).size();
            }
            for (auto &j : thrds)
            {
                if (j.std::thread::joinable()) j.join();
            }
            int st = *std::max_element(Main_str.mas.begin(), Main_str.mas.end());
            thrds.clear();
            Main_str.mas.clear();
        }
        double end = clock();
        Time += (end - start) / 1000;
        std::cout << (end - start) / 1000 << std::endl;
    system("pause");
    return 0;
}
0
Programming
Эксперт
94731 / 64177 / 26122
Регистрация: 12.04.2006
Сообщений: 116,782
23.04.2019, 08:46
Ответы с готовыми решениями:

Вектор потоков
В программе мне требуется иметь доступ одновременно к большому количеству файлов ( чтение ). Чтение...

Создание и завершение процессов и потоков. Приоритеты выполнения потоков
Здравствуйте. Буду очень раз если поможете понять,что конкретно нужно сделать в вот этом...

Класс "вектор" с конструкторами, позволяющими создать нулевой вектор и вектор с произвольным числом элементов
Привет! Задача следующая. Нужно реализовать класс &quot;вектор&quot; с конструкторами, которые позволяют...

Создать иерархию классов вектор и безопасный вектор с проверкой выхода за пределы
Создать иерархию классов вектор и безопасный вектор с проверкой выхода за пределы. Безопасный...

0
23.04.2019, 08:46
IT_Exp
Эксперт
87844 / 49110 / 22898
Регистрация: 17.06.2006
Сообщений: 92,604
23.04.2019, 08:46
Помогаю со студенческими работами здесь

Почему матрица на вектор умножается быстрее чем вектор на матрицу?
Почему матрица на вектор умножается быстрее чем вектор на матрицу?

Даны квадратная матрица A порядка n и вектор b c n элементами. Получить вектор: A^2b
Даны квадратная матрица A порядка n и вектор b c n элементами. Получить вектор: A^2b. Помогите...

матрица на вектор, вроде правильно, а вектор на матрицу? посмотрите пожалуйста?
#include &lt;iostream&gt; #include &lt;iomanip&gt; #include &lt;cstdlib&gt; #include &lt;ctime&gt; using namespace...

Есть квадратная матрица А порядка n и вектор b с n элементами. Получить вектор Аb.
Привет. Не могу разобратся, вот задание: Есть квадратная матрица А порядка n и вектор b с n...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
1
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2024, CyberForum.ru