Форум программистов, компьютерный форум 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) в заданном интервале, используя формулу прямоугольников! Буду крайне благодарен за помощь!!! Есть пример программы, только функция в условии другая, а именно y=5x^2-x+2! Вот её код #include <stdio.h> #include <conio.h> void...
C++ 00 в 20
Здравствуйте! Помогите мне, пожалуйста, понять в чём дело. Почему, если мы какой-то битовый файл переводим в текстовый и хоть что-нибудь в нём после перевода удаляем/меняем, то после этого все нули трансформируются в 20. Т.е. если было, например записано intовское число 7 в виде 07 00 00 00 в 16-ой системе, то потом после малейшего удаления какого-то байтика (разумеется, не в числе 7), получается...
C++ как работает цикл while http://www.cyberforum.ru/cpp-beginners/thread234447.html
Вопрос может и глупый... Но хотелось бы узнать точно.. Вообщем, есть класс-оболочка, который блокирует и освобождает ресурс.. Блокирует он в конструкторе, а освобождает в деструкторе... тогда такой код: while(условие) { какие-то инструкции... ScopeLock lock;
C++ Как сделать выходные параметры у функции? мне нужно чтобы переменная s сохраняла свое значение после работы функции(которая на самом деле процедура, токо я не знал как по другому сделать)) ) void MyFirst(double x,double y,double z,double s) { double p; p=(x+y+z)/2; s=sqrt( p*(p-x)*(p-y)*(p-z) ); } подробнее

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

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

26.01.2011, 21:53. Просмотров 2214. Ответов 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;
}
После регистрации реклама в сообщениях будет скрыта и будут доступны все возможности форума.
 
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2017, vBulletin Solutions, Inc.
Рейтинг@Mail.ru