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

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

Войти
Регистрация
Восстановить пароль
Другие темы раздела
C++ DXDIAG http://www.cyberforum.ru/cpp-beginners/thread234489.html
подскажите!!!!!!!!я работаю с dev c++ строкой System("dxdiag"); я вызываю директикс.вопрос следующий:можно ли в нём перейти на пунк музыка,конечно при помощи языка програмирования.заранее большое...
C++ подключение к мыши подскажите я использую DEV C++ можноли как то подключится к мышке и допустим как то её отключить только сделать это из доса.заранее спасибо!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! http://www.cyberforum.ru/cpp-beginners/thread234476.html
C++ Приближенно вычислить интеграл от функции y=exp(-x) в заданном интервале, используя формулу прямоугольников
Выручите пожалуйста! Необходимо написать прогу на экзамен в крайне короткие сроки(желательно до завтра) Задание - Приближенно вычислить интеграл от функции y=exp(-x) в заданном интервале, используя...
C++ 00 в 20
Здравствуйте! Помогите мне, пожалуйста, понять в чём дело. Почему, если мы какой-то битовый файл переводим в текстовый и хоть что-нибудь в нём после перевода удаляем/меняем, то после этого все нули...
C++ Матрица 4-го порядка http://www.cyberforum.ru/cpp-beginners/thread234462.html
Ребята помогите пожалуйста, не могу решить. :wall: Даны три вещественные квадратные матрицы 4-го порядка. Напечатать ту из них,норма которой наименьшая (считать, что такая матрица одна). В...
C++ как работает цикл while Вопрос может и глупый... Но хотелось бы узнать точно.. Вообщем, есть класс-оболочка, который блокирует и освобождает ресурс.. Блокирует он в конструкторе, а освобождает в деструкторе... тогда такой... подробнее

Показать сообщение отдельно
sanya923
69 / 69 / 19
Регистрация: 26.01.2011
Сообщений: 160

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

26.01.2011, 21:53. Просмотров 2275. Ответов 2
Метки (Все метки)

Здравствуйте!
Помогите пожалуйста решить проблему.
Читать лучше сразу самый низ кода - большой комент, там в принципе вся проблема и заключена.

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;
}
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
 
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2017, vBulletin Solutions, Inc.
Рейтинг@Mail.ru