Форум программистов, компьютерный форум CyberForum.ru
Наши страницы

С++ для начинающих

Войти
Регистрация
Восстановить пароль
 
IcyWind
8 / 8 / 2
Регистрация: 19.09.2011
Сообщений: 272
#1

Двухпоточная сортировка. - C++

08.05.2012, 14:18. Просмотров 401. Ответов 4
Метки нет (Все метки)

Есть сортировка - проверьте на своих машинах (двухядерных или двухпоточных)
напишите сюды свой проц, число элементов, ну и время.
Если будут предложения по ускорению сортировки вторым способом - готов услышать
C++ (Qt)
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
158
159
160
161
162
163
164
#include "stdafx.h"
#include <Windows.h>
#include <vector>
#include <iostream>
#include <algorithm>
#include <time.h>
#include <iomanip>
#include <fstream>
using namespace std;
 
 
static vector<int>::iterator IT1; //для разбивки merge
static vector<int>::iterator IT2;
static long elem_size1;
static long elem_size2;
 
DWORD WINAPI potok_sort(void* param)//получает пару иттераторов и сортирует
{
    vector<int>::iterator* p = static_cast< vector<int>::iterator* > (param);
    sort(*p, *(p+1));
    return 0;
}
 
DWORD WINAPI potok_merge_help(void *param)
{
    vector<int>::iterator * p = static_cast<vector<int>::iterator*> (param);
    auto fromB = p[0];
    auto fromE = p[1];
    auto to = p[2];
    copy(fromB, fromE, to);
    return 0;
}
 
DWORD WINAPI potok_find(void *param) //поиск для разбивки merge
{
 
    vector<int>::iterator * p = static_cast<vector<int>::iterator*> (param);
    auto beg = p[0];
    auto mid = p[1];
    auto end = p[2];//не нужен?
    IT1 = beg;
    elem_size1 = distance(beg, mid)/2;
    advance(IT1, elem_size1);
 
    auto IT1_copy = IT1;
    IT1_copy--;
    auto find = *(IT1_copy);
    IT2 = lower_bound(mid,end,find);
    elem_size2 = distance(mid, IT2);
    return 0;
}
 
DWORD WINAPI merge_help(void *param)
{
    vector<int>::iterator * p = static_cast<vector<int>::iterator*> (param);
    auto from1 = p[0];
    auto from2 = p[1];
    auto to = p[2];
    merge(from1, IT1, from2, IT2, to);
    return 0;
}
 
int _tmain(int argc, _TCHAR* argv[])
{
    setlocale(0, "Rus");
    srand(time(0));
    unsigned N;
    cout<<"Введите кол-во элементов (десятки миллионов)"<<endl;
    cin>>N;
    cout<<endl;
    
    //N=50000000;
    //ofstream FILE("50000000.txt");
 
//for(int i = 0; i<100; i++)
//{
    try 
    {
        vector<int> v1(N);//создание вектора
 
        for(unsigned i = 0; i< N; ++i) //заполнение
            v1[i] = rand();
 
        vector<int> v2(v1);//копируем, чтобы сортировались одиннаковые элементы
 
        //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
        //2 potoka STL merge
        long start1 = clock();
        auto p1_ave = v1.begin();
        advance(p1_ave,v1.size()/2);//p1_ave - итератор на середину вектора
 
        vector<int>::iterator p1[2];//для передачи в поток
        p1[0] = v1.begin();
        p1[1] = p1_ave;
    
        HANDLE potok1 = CreateThread(NULL, 0, potok_sort, p1, 0, NULL); //поток сортирует половину вектора
                                                            
        sort(p1_ave,v1.end());//сортируется вторая половина
        WaitForSingleObject(potok1, INFINITE);                                  //WaitForMultipleObjects(2, potok, FALSE, INFINITE);
        {
            vector<int> helper(v1.size());
            merge(v1.begin(),p1_ave,p1_ave,v1.end(),helper.begin());
            v1.swap(helper);                
        }
        auto time1 = clock() - start1;
        cout<<"Два потока. Merge. Время = "<<0.001*time1<<"Сек"<<endl;
 
        //+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
        //
 
        long start2 = clock();
        auto p2_ave = v2.begin();
        advance(p2_ave,v2.size()/2);//p1_ave - итератор на середину вектора
        
        vector<int>::iterator p2[3];//для передачи в поток
        p2[0] = v2.begin();
        p2[1] = p2_ave;
    
        HANDLE potok2 = CreateThread(NULL, 0, potok_sort, p2, 0, NULL); //поток сортирует половину вектора
                                                            
        sort(p2_ave,v2.end());//сортируется вторая половина
        WaitForSingleObject(potok2, INFINITE);
        
        {
            p2[0] = v2.begin();
            p2[1] = p2_ave;
            p2[2] = v2.end();
            potok2 = CreateThread(NULL,0,potok_find, p2, 0, NULL);
            vector<int> helper(v2.size());
            WaitForSingleObject(potok2,INFINITE);
 
            //cout<<endl<<*IT<<endl;
            p2[0] = v2.begin();
            p2[1] = p2_ave;
            p2[2] = helper.begin();
            potok2 = CreateThread(NULL, 0 , merge_help, p2, 0, NULL);
            
            auto dest = helper.begin();
            advance(dest, elem_size1+elem_size2);
            merge(IT1, p2_ave, IT2, v2.end(), dest); 
            WaitForSingleObject(potok2, INFINITE);
            v2.swap(helper);
        }
        /*for(unsigned int i = 0; i< v2.size();++i)
        cout<<v2[i]<<" ";*/
        auto time2 = clock() - start2;
        cout<<"Двухпоточный Merge. Время = "<<0.001*time2<<"Сек"<<endl;
        //double TIME1 = time1;//*0.001;
        //double TIME2 = time2;//*0.001;
        //cout<<(time1-time2);
        //FILE<<TIME1<<'\t'<<TIME2<<endl;
    }
 
    catch(bad_alloc& ba)
    {
        cout<<"\n++++++++++++++++++++ERROR++++++++++++++++++++\n";
        cout<<"Аварийное завершение программы - не могу выделить столько памяти "<<ba.what()<<"\n";
    }
 
    
//}
    
    return 0;
}
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
08.05.2012, 14:18
Здравствуйте! Я подобрал для вас темы с ответами на вопрос Двухпоточная сортировка. (C++):

Сортировка Шелла. Написал программу, не могу понять, почему сортировка не выполняется - C++
Программа создает динамический массив с рандомным заполнением. Дальше выбор сортировок, пузырьком или сортировка Шелла. Вот она то и не...

Сортировка слиянием. В каком куске кода происходит сортировка и каким именно образом? - C++
Помогите, пожалуйста, разобраться. Подскажите в каком куске кода происходит сортировка и каким именно образом? #include &lt;iostream&gt; ...

Быстрая сортировка (сортировка Хоара) для связных списков - C++
есть у кого готовый алгоритм? или подскажите как реализовать

Быстрая сортировка(сортировка Хоара). Отсортировать фрагмент массива - C++
Мне нужно отсортировать фрагмент массива, расположенный между первым и последним отрицательным элементом. Немогу понять как устоновить...

Сортировка Шелла и пирамидальная сортировка для символов - C++
Здраствуйте, можете пожалуйста привести пример сортировок шелла и пиромидальной сортировки для символов, а то ничего не могу ...

Сортировка вектора по полю(Сортировка вставками) - C++
Здравствуйте! Нужно написать сортировку вектора по полю weight класса tomato. Вот класс: #pragma once #include &lt;iostream&gt; ...

4
Infinity3000
1058 / 577 / 24
Регистрация: 03.12.2009
Сообщений: 1,255
08.05.2012, 14:44 #2
Ноут Intel Core i3 , ATI Mobility Radeon HD 5650 1024 MB, 3 GB Memory, 320 GB HDD

Процессор был загружен на 25% иногда были скачки до 48 - 52%, использовалось ~1 GB оперативной!
0
Миниатюры
Двухпоточная сортировка.  
IcyWind
8 / 8 / 2
Регистрация: 19.09.2011
Сообщений: 272
08.05.2012, 14:45  [ТС] #3
P.s. Забыл добавить. Компилировать ОБЯЗАТЕЛЬНО нужно в режиме "Release", а не "Debug"
0
Infinity3000
1058 / 577 / 24
Регистрация: 03.12.2009
Сообщений: 1,255
08.05.2012, 14:50 #4
Цитата Сообщение от IcyWind Посмотреть сообщение
P.s. Забыл добавить. Компилировать ОБЯЗАТЕЛЬНО нужно в режиме "Release", а не "Debug"

Visual Studio 2010
0
Миниатюры
Двухпоточная сортировка.  
Infinity3000
1058 / 577 / 24
Регистрация: 03.12.2009
Сообщений: 1,255
08.05.2012, 14:53 #5
150 000 000
0
Миниатюры
Двухпоточная сортировка.  
08.05.2012, 14:53
MoreAnswers
Эксперт
37091 / 29110 / 5898
Регистрация: 17.06.2006
Сообщений: 43,301
08.05.2012, 14:53
Привет! Вот еще темы с ответами:

2 сортировки: пирамидальная сортировка и сортировка слиянием - C++
Реализовать два улучшенных алгоритма сортировки. Для каждого алгоритма вычислить показатель качества сортировки (количество операций, т.е....

C/C++ FAQ :: Быстрая сортировка (сортировка Хоара) - C++
Вопрос, скорее академический, по мотивам реализации. Вот в faq приведена реализация этого метода сортировки на C++. В коде есть следующий...

Быстрая сортировка (сортировка методом Хоара) - C++
Ввести массив x1,x2,...,x20 в диапазоне . Требуется расположить отрицательные элементы в порядке убывания. Вывести массивы до и после...

Сортировка Хоара / Быстрая сортировка - C++
Доброго времени суток. Написал реализацию алгоритма быстрой сортировки. void SortHhoar(int *arr,int f,int l)//Хоара { int mid = (f...


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

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

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2017, vBulletin Solutions, Inc.
Рейтинг@Mail.ru