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

Потоки. WaitForSingleObject. - C++

Восстановить пароль Регистрация
 
Рейтинг: Рейтинг темы: голосов - 18, средняя оценка - 4.72
sanya923
69 / 69 / 19
Регистрация: 26.01.2011
Сообщений: 160
26.01.2011, 21:53     Потоки. WaitForSingleObject. #1
Здравствуйте!
Помогите пожалуйста решить проблему.
Читать лучше сразу самый низ кода - большой комент, там в принципе вся проблема и заключена.

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
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
#include "stdafx.h"
#include <iostream>
#include "windows.h"
#include "stdlib.h"
#include "stdio.h"
#include <string>
using namespace std;
 
class TQuery
{
    /*только public оставил на свое усмотрение*/
     public:
         static TQuery *head,*tail;
         static int count_query,count_obs;
         int p,v,i;
         TQuery *next,*pre;
         TQuery(int p_, int v_, int i_) : p(p_), v(v_), i(i_), next(NULL), pre(NULL)
         {}
         //добавление элемента в очередь
         void Past(TQuery *q)
         {
             count_query+=1;
             TQuery *poisk;
             poisk=head;
             if (tail == NULL)
             {
                 tail=q;
                 head=q;
             }
             else
             {
                 if (q->p>poisk->p)
                 {
                     poisk->pre=q;
                     q->next=poisk;
                     head=q;
                 }
                 else
                 {
                     if (poisk->next==NULL)
                     {
                         q->pre=poisk;
                         poisk->next=q;
                         tail=q;
                     }
                     else
                     {
                         while ((q->p<=poisk->p)&&(poisk->next!=NULL))
                             poisk=poisk->next;
                         if (q->p==poisk->p)
                         {
                             poisk->next=q;
                             q->pre=poisk;
                             tail=q;
                         }
                         else
                         {
                             q->pre=poisk->pre;
                             poisk->pre->next=q;
                             poisk->pre=q;
                             q->next=poisk;
                         }
                     }
                 }
             }
         }
         //удаление элемента из очереди
         void UdElm()
         {
             TQuery *ud;
             count_obs+=1;
             count_query-=1;
             if (head->next!=NULL)  
             {
                 head=head->next;
                 head->pre->next=NULL;
             }
             else
             {
                 StartClear();
             }
             delete ud;
         }
         //обнуление параметров
         void StartClear()
         {head=NULL;tail=NULL;count_query=0;}
         void ObsClear()
         {count_obs=0;}
};
 
HANDLE sp; //для семафора
HANDLE s_kanal[3]; //для семафоров
HANDLE uvv[3]; //для устройст(потоков) обслуживающих заявки
HANDLE a,b; //а-поток поступающих заявок,b-поток опрашивающий устройства
bool p_kanal[3];  //признак занятости устройства
TQuery *q_elm_kanal[3]; //для обслуживающихся заявок
 
//поток с поступающими заявками
int fThread1()
{
    int i=0;
    double p_,v_,t1;
    TQuery *z;
    while (true)
    {
        WaitForSingleObject(sp,INFINITE);
            i+=1;
            p_=rand(); v_=rand(); p_=p_/32768; v_=v_/32678;
            z = new TQuery(unsigned(20*p_+0.5),unsigned(8*v_+0.5),i);
            z->Past(z);
            cout<<"заявка № "<<i<<" встала в очередь (приоритет "<<z->p<<", объем "<<z->v<<", № "<<z->i<<")"<<endl;
        ReleaseSemaphore(sp,1,NULL);
        t1=rand();
        t1=t1/32678;
        t1=1000+2000*t1;
        Sleep(unsigned(t1));
    }
    return 0;
}
 
//поток обслуживающего устройства(три устройства будет)
int fThread2(int i_)
{
    double t2;
    while (true)
    {
        WaitForSingleObject(s_kanal[i_],INFINITE);//-------здесь поток виснет--------
        t2=rand(); t2=t2/32678; t2=1000*i_+1000*q_elm_kanal[i_]->v;
        Sleep(unsigned(t2));
        cout<<"   устройство № "<<i_<<" обслужило заявку № "<<q_elm_kanal[i_]->i<<" за "<<unsigned(t2)<<endl;
        p_kanal[i_]=true;
    }
    return 0;
}
 
//поток опрашивающий устройства
int fThread3()
{
    int i;
    while (true)
    {
        if (TQuery::count_query!=0)
        {
            for (i=0;i<3;i++)
            {
                WaitForSingleObject(sp,INFINITE);
                    if (p_kanal[i])
                    {
                        p_kanal[i]=false;
                        q_elm_kanal[i]=TQuery::head;
                        TQuery::UdElm;
                        cout<<"   заявка № "<<q_elm_kanal[i]->i<<" поступила на устройство № "<<i<<endl;
                        ReleaseSemaphore(s_kanal[i],1,NULL);
                        ReleaseSemaphore(sp,1,NULL);
                        break;
                    }
                ReleaseSemaphore(sp,1,NULL);
            }
        }
    }
    return 0;
}
 
int TQuery::count_obs;
int TQuery::count_query;
TQuery * TQuery::head;
TQuery * TQuery::tail;
 
int main()
{
    TQuery::StartClear; TQuery::ObsClear;
    //поток с поступающими заявками сразу начинает работать поэтому 1
    sp=CreateSemaphore(NULL,1,1,NULL);
    int i;
    for (i=0;i<3;i++)
    {
        /*когда потоки устройств запускаются они должны ждать,
        поэтому 0 поставил*/
        s_kanal[i]=CreateSemaphore(NULL,0,1,NULL);
        p_kanal[i]=true;
    }
    a=CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)fThread1,NULL,NULL,NULL);
    for (i=0;i<3;i++)
    {
        /*здесь виснет при первом заходе(см. fThread2)
        и на второй круг не идет, ну и следовательно и "b" тоже не запускается,
        а в нем как раз ReleaseSemaphore, который должен просигнализировать.
        поток "a" при этом продолжает работать.
        в делфи писал, всё было норм. хотел разобраться с этим же и в с++.
        думается я с потоками где-то налажал, неже ли с семафорами,
        т.к. в делфи для синхронизации также пользовался API, т.е. CreateSemaphore,
        WaitForSingleObject,ReleaseSemaphore, а вот поток создавал подругому, не с
        помощью CreateThread*/
        uvv[i]=CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)fThread2(i),NULL,NULL,NULL);
    }
    b=CreateThread(NULL, NULL, (LPTHREAD_START_ROUTINE)fThread3,NULL,NULL,NULL);
    return 0;
}
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
26.01.2011, 21:53     Потоки. WaitForSingleObject.
Посмотрите здесь:

WaitForSingleObject вешает интерфейс C++
Потоки C++
потоки C++
Потоки C++
WaitForSingleObject и многопоточность C++
C++ WaitForSingleObject
C++ потоки
C++ Приложение останавливается на WaitForSingleObject

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

Или воспользуйтесь поиском по форуму:
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
Iron Bug
22 / 22 / 0
Регистрация: 06.12.2010
Сообщений: 125
26.01.2011, 22:52     Потоки. WaitForSingleObject. #2
в строке 194 fThread2(i) - эта конструкция есть ВЫЗОВ функции fThread2() с параметром i. возвращаемое функцией значение будет передано в качестве АДРЕСА некоей "функции". естественно, программа шлёпнется. если хочешь передавать параметры - они передаются в других параметрах функции CreateThread, а сама функция передаётся как адрес, т.е. просто fThread2.
sanya923
69 / 69 / 19
Регистрация: 26.01.2011
Сообщений: 160
27.01.2011, 18:21  [ТС]     Потоки. WaitForSingleObject. #3
Iron Bug, спасибо за совет.
Я попробовал исправить, но у меня чет как-то не вышло. Решил упростить задачу:
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
#include "stdafx.h"
#include <iostream>
#include "windows.h"
using namespace std;
 
HANDLE h1,h2;
HANDLE sp1;
 
DWORD WINAPI Thread1(LPVOID lpParam1)
{
    for (int i=0;i<100;i++)
    {
 
        WaitForSingleObject(sp1,INFINITE);
            cout<<"Potok "<<1<<endl;
            ReleaseSemaphore(sp1,1,NULL);
                     Sleep(30);
    }
    return 0;
}
 
DWORD WINAPI Thread2(LPVOID lpParam1)
 
{
    for (int j=0;j<100;j++)
    {
        WaitForSingleObject(sp1,INFINITE);
                         cout<<"Potok "<<2<<endl;
            ReleaseSemaphore(sp1,1,NULL);
        Sleep(5);
    }
    return 0;
}
 
VOID main()
{
    sp1=CreateSemaphore(NULL,1,1,NULL);
 
    h1 = CreateThread(NULL,0,Thread1,NULL,0,NULL);
    h2 = CreateThread(NULL,0,Thread1,NULL,0,NULL);
    
    int uo;
    cin>>uo;
}
Здесь два потока выводят свои номера. Учитывая, что у 2-го задержка меньше, то примерно через каждые пять выводов 2-го должен выводить 1-ый. Но выводит только первый.
Написал тоже самое в Delphi, всё работает, единственное как я уже говорил, я там потоки создаую по другому, но для синхронизации всё тоже самое использую.
Ни как не могу понять как тут это работает.

Добавлено через 10 минут
Всё нашел ошибку. При создании второго передаую Thread1/
Yandex
Объявления
27.01.2011, 18:21     Потоки. WaitForSingleObject.
Ответ Создать тему
Опции темы

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