-
Notifications
You must be signed in to change notification settings - Fork 0
/
header.h
124 lines (78 loc) · 2.62 KB
/
header.h
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
//
// header.h
// SecondTask
//
// Created by Аким Каленюк on 22.05.2021.
//
#include <iostream>
#include <pthread.h>
#include <time.h>
#include <vector>
#include <fstream>
#include <string>
// количество элементов в массиве
// количество потоков
#define THREAD_MAX 4
using namespace std;
vector<int> a;
int part = 0;
unsigned long MAX;
// функция слияния для объединения двух частей
void merge(int low, int mid, int high) {
int* left = new int[mid - low + 1];
int* right = new int[high - mid];
// n1 это размер левой части, а n2 это размер правой части
int n1 = mid - low + 1, n2 = high - mid, i, j;
// сохраняем значения в левой части
for (i = 0; i < n1; i++)
left[i] = a[i + low];
// сохраняем значения в правой части
for (i = 0; i < n2; i++)
right[i] = a[i + mid + 1];
int k = low;
i = j = 0;
// объединяем влево и вправо в порядке возрастания
while (i < n1 && j < n2) {
if (left[i] <= right[j])
a[k++] = left[i++];
else
a[k++] = right[j++];
}
// вставляем оставшиеся значения слева
while (i < n1) {
a[k++] = left[i++];
}
// вставляем оставшиеся значения справа
while (j < n2) {
a[k++] = right[j++];
}
}
// объединить функцию сортировки
void merge_sort(int low, int high) {
// вычисление средней точки массива
int mid = low + (high - low) / 2;
if (low < high) {
// вызов первой половины
merge_sort(low, mid);
// вызов второй половины
merge_sort(mid + 1, high);
// объединяем две половины
merge(low, mid, high);
}
}
// функция потока для многопоточности
void* merge_sort(void* arg) {
// какая часть из 4-х частей
int thread_part = part++;
// вычисление низкого и высокого
int low = thread_part * (MAX / 4);
int high = (thread_part + 1) * (MAX / 4) - 1;
// оцениваем середину
int mid = low + (high - low) / 2;
if (low < high) {
merge_sort(low, mid);
merge_sort(mid + 1, high);
merge(low, mid, high);
}
return 0;
}