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

параллельная сортировка массива - C++

Восстановить пароль Регистрация
 
Рейтинг: Рейтинг темы: голосов - 12, средняя оценка - 4.75
!Master P!
0 / 0 / 0
Регистрация: 07.05.2011
Сообщений: 7
20.12.2012, 00:43     параллельная сортировка массива #1
собственно задание:
Параллельный алгоритм сортировки массива чисел M[1:N] заключается в следующем. L параллельно работающих потока находят в своем участке массива максимальный элемент и передают его потоку – менеджеру. Поток – менеджер собирает L максимальных элементов и записывает их в массив P[1: L]. Определив среди них максимальное, менеджер переписывает это значение в результирующий массив MR[1:N] , и требует у потока, который передал значение следующее число. Если поток передал последнее число, он снимается с выполнения. Если какой-либо из потоков "отстает" от остальных (то есть в массиве Р нет числа от этого потока), его приоритет временно увеличивается.

чтото я не могу понять как синхронизировать потоки в опен мп помогите с этим или доделайте то чего не хватает очень прошу помогите нубику разобраться ктонибудь

решение нужно очень срочно

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
#include "stdafx.h"
#include <omp.h>
#include <iostream>
using namespace std;
 
int _tmain(int argc, _TCHAR* argv[])
{
    bool flag=false;
    int size=10,rank=0,num=0,length;
    int* mas=new int[size];
    
    for (int i=0;i<size;i++)
    {
        mas[i]=rand()%10;
    }
    num=omp_get_max_threads();
    do
    {
        switch(num)
        {
        case 1:
            omp_set_num_threads(1);flag=true;
            break;
        case 2:
            if (size%2==0)
            {
                omp_set_num_threads(2);num=2;flag=true;
            }
            else {omp_set_num_threads(1); num=1;flag=false;}
            break;
        case 3:
            if (size%3==0)
            {
                omp_set_num_threads(3);num=3;flag=true;
            }
            else {omp_set_num_threads(2); num=2;flag=false;}
            break;
        case 4:
            if (size%4==0)
            {
                omp_set_num_threads(4);num=4;flag=true;
            }
            else {omp_set_num_threads(3); num=3;flag=false;}
            break;
        default:
            num--;flag=false;
            break;
        }
    } while(!flag);
    length=size/num;
    int kol;
    int* max_el=new int[num];
    for (int i=0;i<num;i++)
    {
        max_el[i]=0;
    }
    for (int i=0;i<size;i++)
    {
        cout<<mas[i]<<" ";
    }
    cout<<endl;
 
#pragma omp parallel private(rank,kol)
{
    rank=omp_get_thread_num();
    kol=length;
#pragma omp critical
    {
        cout<<"thread num is "<<rank<<endl;
        for(int i=rank*length,j=0;i<(rank+1)*length;i++,j++)
        {
            cout<<mas[i]<<" ";
        }
        cout<<endl;
    }
    do
    {
        kol--;
        for(int i=rank*length;i<(rank+1)*length;i++)
        {
            for(int i=rank*length;i<(rank+1)*length-1;i++)
            {
                if(mas[i]<mas[i+1])
                {
                    if(max_el[rank]==0)
                    {
                        max_el[rank]=mas[i];
                    }
                }
            }
        }
    } while(kol!=0);
}
 
for(int i=0;i<size;i++)
{
    for(int j=0;i<num-2;j++)
    {
        if (max_el[j]>max_el[j+1])
        {
            mas[i]=max_el[j];max_el[j]=0;
        }
    }
}
 
for (int i=0;i<size;i++)
{
    cout<<mas[i]<<" ";
}
cout<<endl;
delete[] mas;
delete[] max_el;
system("PAUSE");
return 0;
}
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
20.12.2012, 00:43     параллельная сортировка массива
Посмотрите здесь:

C++ Параллельная работа с документами
Параллельная прямая C++
Быстрая сортировка(сортировка Хоара). Отсортировать фрагмент массива C++
C++ Параллельная работа лифтов
C++ Параллельная сортировка, протестировать алгоритм
Параллельная обработка C++
C++ Параллельная обработка файлов
Параллельная работа с файлами C++

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

Или воспользуйтесь поиском по форуму:
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
Ответ Создать тему
Опции темы

Текущее время: 18:38. Часовой пояс GMT +3.
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2016, vBulletin Solutions, Inc.
Рейтинг@Mail.ru