Потоки. Синхронизация. Передача параметра при создании потока.

@sanya923 · Регистрация: 26.01.2011

Author24 — интернет-сервис помощи студентам

Здравствуйте!
Разбираюсь с потоками. Возникли проблемы то ли с синхронизацией, то ли с созданием потоков и передачей в потоковую функцию параметров, я конкретно не знал с чем. Ну и в концов замучившись полностью, я решил написать небольшой кодик, всё же с ним легче разбираться.

C++

#include "stdafx.h"
#include <iostream>
#include "windows.h"
#include "stdlib.h"
using namespace std;
 
 
HANDLE sp,uvv[3];
 
DWORD WINAPI Thread2(LPVOID lpParam1)
{
    double t1;
    int *i = new int;
    *i=*(int*)lpParam1;
    while (true)
    {
        WaitForSingleObject(sp,INFINITE);
            cout<<"Potok "<<*i<<endl;
        ReleaseSemaphore(sp,1,NULL);
        t1=rand();
        t1=t1/32678;
        t1=3000*t1;
        Sleep(unsigned(t1));
    }
    return 0;
}
 
 
VOID main(VOID)
{
    int rt;
    sp=CreateSemaphore(NULL,1,1,NULL);
    for (int i=0;i<3;i++)
    {
        uvv[i]=CreateThread(NULL,0,Thread2,&i,0,NULL);
                WaitForSingleObject(sp,INFINITE);
              cout<<"Sozdan prozess "<<i<<endl;
        ReleaseSemaphore(sp,1,NULL);
    }
    cin>>rt;
}

И обнаружил следующее:
Если я коменчу 37 и 39 строчку, то при выводе 19 появляется номер 3, хотя его не должно быть, при тройке же цикл в блок не входит уже, а также выводятся не все номера, т.е. 0,1,2, а два каких-то. Если не коменчу, то всё норм. По логике без них должно же всё нормально работать. В Delphi писал, было всё норм. А также я не пойму как влияет на работу 32 и 41 строчка, если их закоментить, то дохнет.

Добавлено через 12 часов 40 минут
Обойти 32 и 41 я не смог, особо понять почему при закоменчивании 37 и 39 непонятные дела происходят, но зато логически переписал по другому. Добавил еще один семафор, чтобы контролировать цикл, раз он раньше каким-то образом убегает вперед, чем создаётся поток.

C++

#include "stdafx.h"
#include <iostream>
#include "windows.h"
#include "stdlib.h"
using namespace std;
 
 
HANDLE sp,sk,uvv[3];
 
DWORD WINAPI Thread2(LPVOID lpParam1)
{
    double t1;
    int *i = new int;
    *i=*(int*)lpParam1;
    ReleaseSemaphore(sk,1,NULL);
    while (true)
    {
        WaitForSingleObject(sp,INFINITE);
            cout<<"Potok "<<*i<<endl;
        ReleaseSemaphore(sp,1,NULL);
        t1=rand();
        t1=t1/32678;
        t1=3000*t1;
        Sleep(unsigned(t1));
    }
    return 0;
}
 
 
VOID main(VOID)
{
    int rt;
    sp=CreateSemaphore(NULL,1,1,NULL);
    sk=CreateSemaphore(NULL,0,1,NULL);
    for (int i=0;i<3;i++)
    {
                 uvv[i]=CreateThread(NULL,0,Thread2,&i,0,NULL);
                 WaitForSingleObject(sk,INFINITE);
    }
    cin>>rt;
}

	28.01.2011, 10:35

Опции темы