Сортировка массива методом пузырька в несколько потоков

[rostik123]

Как ето зделать c помощью WinApi .
Программа может работать и не всегда корректно, мне главное чтобы посмотреть как это происходит ...

[eoln]

Примерно так

#include <stdio.h>
#include <windows.h>

HANDLE hThread1;
const int n=10;
int a[n], i, j;//всё глобальное, потому что лень

DWORD WINAPI Thread2( void* pParams )//поток для обмена
{
    int tmp=a[i];
    a[i]=a[j];
    a[j]=tmp;
    Sleep(50);//для наглядности
}

DWORD WINAPI Thread1( void* pParams )//поток сортировки
{
    for (i=0;i<n-1;i++)
    for (j=i+1;j<n;j++)
    if (a[i]>a[j])
    {
        HANDLE hThread2=CreateThread(NULL,0,Thread2,NULL,0,NULL);//запускаем обмен в отдельном потоке
        WaitForSingleObject(hThread2,INFINITE);//и ждем окончания этого потока
        //если убрать, то сортировка будет неправильной
        CloseHandle(hThread2);
    }
}

int main()
{
    for (i=0; i<n; i++) {a[i]=rand()%10; printf("%d ", a[i]); }; printf("\n");

    hThread1=CreateThread(NULL,0,Thread1,NULL,0,NULL);//запускаем сортировку
    WaitForSingleObject(hThread1,INFINITE);//ждём окончания

    for (i=0; i<n; i++) printf("%d ", a[i]);
}

Более подробно с передачей параметров в потоки http://msdn.microsoft.com/en-us/libr...(v=vs.85).aspx

[rostik123]

спасибо, важна для меня информация, буду разбираться с ней ...

[LynXzp]

Примерно так

А ха ха. Ну формально ты прав.

Но ппц. Да, так быстрее чем одним потоком )))))))))))

[eoln]

Сообщение от LynXzp

Но ппц. Да, так быстрее чем одним потоком )))))))))))

Ну дык человеку ведь надо именно в несколько потоков, ИМХО это не реальная задача, а учебная.

[LynXzp]

Но в один и тот же момент всегда одним потоком.
получилась "многопоточная программа сортировки" без "многопоточной сортировки".

Программа может работать и не всегда корректно, мне главное чтобы посмотреть как это происходит ...

Может так?

#include <stdio.h>
#include <windows.h>

HANDLE hThread1;
const int n=10;
int a[n], i, j;//всё глобальное, потому что лень

DWORD WINAPI Thread1( void* pParams )//поток сортировки
{
    for (i=0;i<n-1;i++)
    for (j=i+1;j<n;j++)
    if (a[i]>a[j])
    {    int tmp=a[i];
         a[i]=a[j];
         a[j]=tmp;
    }
}

DWORD WINAPI Thread2( void* pParams )//поток сортировки
{
    for (i=n-1;i>0;i--)
    for (j=n;j>i+1;j--)
    if (a[i]<a[j])
    {    int tmp=a[i];
         a[i]=a[j];
         a[j]=tmp;
    }
}

int main()
{
    for (i=0; i<n; i++) {a[i]=rand()%10; printf("%d ", a[i]); }; printf("\n");

        HANDLE hThread1=CreateThread(NULL,0,Thread1,NULL,0,NULL);
        HANDLE hThread2=CreateThread(NULL,0,Thread2,NULL,0,NULL);
        WaitForSingleObject(hThread1,INFINITE);
        WaitForSingleObject(hThread2,INFINITE);
        CloseHandle(hThread1);
        CloseHandle(hThread2);

    for (i=0; i<n; i++) printf("%d ", a[i]);
}

Не копмилил даже, и не уверен что сработает, но главное суть - сортировка пузырьком в 2 стороны сразу, никакого контроля, никаких синхронизаций =))

[eoln]

Ну если некорректно, то да )))
Что-то не идёт на ум способ без остановок потоков. С синхронизацией так

#include <stdio.h>
#include <windows.h>

HANDLE hEvent1, hEvent2;

const int n=100;
int a[n];

DWORD WINAPI Thread1( void* pParams )//поток сортировки
{
    for (int i=0;i<n-1;i++)
    for (int j=i+1;j<n;j++){
        WaitForSingleObject(hEvent1, 100);
        if (a[i]>a[j])
        {    int tmp=a[i];
             a[i]=a[j];
             a[j]=tmp;
        }
        ResetEvent(hEvent1);
        SetEvent(hEvent2);
    }
}

DWORD WINAPI Thread2( void* pParams )//поток сортировки
{
    for (int i=n-2;i>=0;i--)
    for (int j=n-1;j>=i+1;j--){
        WaitForSingleObject(hEvent2, 100);
        if (a[i]>a[j])
        {    int tmp=a[i];
             a[i]=a[j];
             a[j]=tmp;
        }
        ResetEvent(hEvent2);
        SetEvent(hEvent1);
    }
}

int main()
{
    for (int i=0; i<n; i++) {a[i]=rand()%10; printf("%d ", a[i]); }; printf("\n");

        hEvent1 = CreateEvent( NULL, false, true, NULL );
        hEvent2 = CreateEvent( NULL, false, false, NULL );
        HANDLE hThread1=CreateThread(NULL,0,Thread1,NULL,0,NULL);
        HANDLE hThread2=CreateThread(NULL,0,Thread2,NULL,0,NULL);
        WaitForSingleObject(hThread1,INFINITE);
        WaitForSingleObject(hThread2,INFINITE);
        CloseHandle(hThread1);
        CloseHandle(hThread2);
        CloseHandle(hEvent1);
        CloseHandle(hEvent2);

    for (int i=0; i<n; i++) printf("%d ", a[i]);
}

вроде как параллельно работают, но шаги по очереди делают. Но ведь в одном ядре многозадачности тоже вроде как бы и нет и как бы и есть

[UPD]
Что-то тупанул )) Надо было вместо событий критическую секцию (аля ей подобное) ставить, тогда бы потоки немного соревновались

[rostik123]

спасибо, буду разбираться с вашими примерами и на основе их делать свои программы в целях обучения ...