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

rand() в потоке - C++

Восстановить пароль Регистрация
 
tiptop_crazy
0 / 0 / 0
Регистрация: 27.05.2012
Сообщений: 39
05.04.2013, 16:09     rand() в потоке #1
Запускается n потоковых функций, каждый из них приостанавливается во время своего выполнения, а в главное программе должен перезапускаться. Перед остановкой потока ему нужно задать произвольный приоритет( от idle до above_normal). Но получается, что всем потокам рандом даёт одно и то же число. Точнее он, наверное, не пересчитывается. Подскажите, пожайлуста, как исправить? (В коде напротив рандома комментарий стоит)
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
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
165
#include <stdio.h>
#include <iostream>
#include <time.h>
 
#include <windows.h>
using namespace std;
 
DWORD WINAPI work(LPVOID iNum);
CRITICAL_SECTION cs;
int count=0;
 
struct data
{
    float mass[9];
    float res;
    void copy(float a[])
    {
        for(int i=0;i<9;i++)
            mass[i]=a[i];
    }
};
 
data* ThreadData;
 
int main(  )
{   
   FILE *stream;  
   InitializeCriticalSection(&cs);
   if( (stream = fopen( "in.txt", "r" )) == NULL )
   {
      cout<<"Main file not found\n";
   }
   int count=0;
   fscanf(stream,"%d",&count);
   char dummy;
   fscanf(stream,"%c",&dummy);
 
   char** names;
   if(count!=0)
   {
        names=new char*[count];
        for(int i=0;i<count;i++)
        {           
            names[i]=new char[200];
            fgets( names[i], 200, stream  );            
            names[i][strlen(names[i])-1]=0;     
        }           
   }
   else
   {
        cout<<"0 files\n";
        system("PAUSE");
        return 2;
   }   
   fclose( stream );
 
   ThreadData=new data[count];
 
   EnterCriticalSection(&cs);
   for(int i=0;i<count;i++)
   {
        stream=fopen( names[i],"r");
        if(stream==NULL)
        {
            cout<<"File "<< names[i]<<" not found\n";
            system("PAUSE");
            return 1;
        }
        float mass[9];
        for (int j = 0; j < 9; j++)
        {
            fscanf(stream, "%f", &mass[j]);      
        }
        ThreadData[i].copy(mass);
        fclose(stream);
    }
   LeaveCriticalSection(&cs);
    for(int i=0;i<count;++i)            
        delete [] names[i]; 
    delete[] names;
    HANDLE*     hThread=new HANDLE[count];
    DWORD*  IDThread=new DWORD[count];
    for(int i=0;i<count;i++)
        hThread[i] = CreateThread(NULL, 0, work, (void*)i, 0, &IDThread[i]);
    Sleep(500);
    
    for(int i=0;i<count;i++)
    {
        
        for(int level=0;level<5;level++)
        {
            if(GetThreadPriority(hThread[i])==THREAD_PRIORITY_IDLE&&level==0)
                ResumeThread(hThread[i]);
            else if(GetThreadPriority(hThread[i])==THREAD_PRIORITY_LOWEST&&level==1)
                ResumeThread(hThread[i]);
            else if(GetThreadPriority(hThread[i])==THREAD_PRIORITY_BELOW_NORMAL&&level==2)
                ResumeThread(hThread[i]);
            else if(GetThreadPriority(hThread[i])==THREAD_PRIORITY_NORMAL&&level==3)
                ResumeThread(hThread[i]);
            else if(GetThreadPriority(hThread[i])==THREAD_PRIORITY_ABOVE_NORMAL&&level==3)
                ResumeThread(hThread[i]);
        }
    }
    if (WaitForMultipleObjects(count, hThread, TRUE, INFINITE) == WAIT_FAILED)
    {
        cout << "Wait for multiple objects failed." << endl;
        cout << "Input any char to exit." << endl;
        system("PAUSE");        
    }
    
    for(int i=0;i<count;i++)
        CloseHandle(hThread[i]);
    
    DeleteCriticalSection(&cs);
    
    for(int i=0;i<count;i++)
        cout<<"File "<<(i+1)<<" result: "<<ThreadData[i].res<<endl;
    delete [] ThreadData;
 
   system("PAUSE");
   return 0;
}
 
DWORD WINAPI work(LPVOID arg)
{
    EnterCriticalSection (&cs);
    count++;
    char IncBuffer[3];  
    itoa(count,IncBuffer,10);       
    char IncOut[10]="title ";
    strcat(IncOut,IncBuffer);
    system(IncOut); 
    LeaveCriticalSection(&cs);
    HANDLE hThread = GetCurrentThread();
    srand(time(0));                                                                 
    int choise=rand()%5;                                         //тут рандом
    switch(choise)
    {
    case 0: SetThreadPriority(hThread, THREAD_PRIORITY_IDLE);cout<<choise<<endl;break;
    case 1: SetThreadPriority(hThread, THREAD_PRIORITY_LOWEST);cout<<choise<<endl;break;
    case 2: SetThreadPriority(hThread, THREAD_PRIORITY_BELOW_NORMAL);cout<<choise<<endl;break;
    case 3: SetThreadPriority(hThread, THREAD_PRIORITY_NORMAL);cout<<choise<<endl;break;
    case 4: SetThreadPriority(hThread, THREAD_PRIORITY_ABOVE_NORMAL);cout<<choise<<endl;break;
    }   
    
    int num = (int)(arg);
    SuspendThread(hThread);   
    EnterCriticalSection (&cs); 
    ThreadData[num].res = ThreadData[num].mass[0] * ThreadData[num].mass[4] * ThreadData[num].mass[8] +
        ThreadData[num].mass[2] * ThreadData[num].mass[3] * ThreadData[num].mass[7] + 
        ThreadData[num].mass[1] * ThreadData[num].mass[5] * ThreadData[num].mass[6] -
        ThreadData[num].mass[2] * ThreadData[num].mass[4] * ThreadData[num].mass[6] -
        ThreadData[num].mass[1] * ThreadData[num].mass[3] * ThreadData[num].mass[8] -
        ThreadData[num].mass[0] * ThreadData[num].mass[5] * ThreadData[num].mass[7];
    count--;
    char DecBuffer[3];  
    itoa(count,DecBuffer,10);       
    char DecOut[10]="title ";
    strcat(DecOut,DecBuffer);
    system(DecOut);
    LeaveCriticalSection(&cs);
 
    return 0;
}
}
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
05.04.2013, 16:09     rand() в потоке
Посмотрите здесь:

rand C++
rand() C++
C++ rand() в потоке
C++ Не могу создать поток( Нужно чтобы функция запускается в потоке и работала там пока не закроем в потоке)
rand()%(-20)%(20); C++
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
Tulosba
:)
Эксперт С++
4378 / 3221 / 297
Регистрация: 19.02.2013
Сообщений: 9,044
05.04.2013, 16:29     rand() в потоке #2
Проблема тут:
Цитата Сообщение от tiptop_crazy Посмотреть сообщение
srand(time(0));
Для всех потоков генератор инициализируется одинаковым временем. Можно сделать завязку на ID потока например.
tiptop_crazy
0 / 0 / 0
Регистрация: 27.05.2012
Сообщений: 39
05.04.2013, 20:47  [ТС]     rand() в потоке #3
Я понимаю, что можно написать srand(num), но тогда оно при всех запусках будет давать одни и те же числа..

Добавлено через 10 минут
Всё, решил проблему так:
time_t timer;
int a=time(&timer)+num;
srand(a);
NeonLost
Пес войны
 Аватар для NeonLost
74 / 85 / 3
Регистрация: 23.02.2012
Сообщений: 653
05.04.2013, 22:53     rand() в потоке #4
я решал это вот так...теперь это все и в стд есть...)
C++
1
2
3
4
5
6
7
8
9
unsigned long int Parser::GetRndNumber()
{
    typedef boost::mt19937 RNGType;
    boost::random::random_device rd;
    RNGType rng(rd());
    boost::uniform_int<> one_to_one( 10000000, 100000000 );
    boost::variate_generator< RNGType, boost::uniform_int<> >dice(rng, one_to_one);
    return dice();
}
Yandex
Объявления
05.04.2013, 22:53     rand() в потоке
Ответ Создать тему
Опции темы

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