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

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

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

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

08.05.2012, 14:18. Просмотров 384. Ответов 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;
}
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
08.05.2012, 14:18     Двухпоточная сортировка.
Посмотрите здесь:

С++ сортировка C++
C++ сортировка
Сортировка C++
Сортировка C++
Сортировка C++
C++ сортировка
Сортировка C++
C++ Сортировка
Сортировка C++
C++ Сортировка
Сортировка C++
сортировка C++

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

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

Visual Studio 2010
Миниатюры
Двухпоточная сортировка.  
Infinity3000
1058 / 577 / 24
Регистрация: 03.12.2009
Сообщений: 1,255
08.05.2012, 14:53     Двухпоточная сортировка. #5
150 000 000
Миниатюры
Двухпоточная сортировка.  
Yandex
Объявления
08.05.2012, 14:53     Двухпоточная сортировка.
Ответ Создать тему
Опции темы

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