0 / 0 / 0
Регистрация: 17.05.2015
Сообщений: 15
1

Синхронизация потоков

17.05.2015, 13:07. Показов 2575. Ответов 24
Метки нет (Все метки)

Author24 — интернет-сервис помощи студентам
Помогите синхронизировать два потока на Win32 Api.
1й выводит числовую последовательность, 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
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
// KURSS.cpp: определяет точку входа для приложения.
//
 
#include "stdafx.h"
#include "KURSS.h"
 
#define MAX_LOADSTRING 100
 
// Глобальные переменные:
HINSTANCE hInst;                                // текущий экземпляр
TCHAR szTitle[MAX_LOADSTRING];                  // Текст строки заголовка
TCHAR szWindowClass[MAX_LOADSTRING];            // имя класса главного окна
RECT crect;
HDC hdc;
int x,y, n[3]={0,0,0}, p[3];
HWND static1;
HWND hWnd;
HANDLE hTh[4];
LPDWORD dwTh[4];
 
// Отправить объявления функций, включенных в этот модуль кода:
ATOM                MyRegisterClass(HINSTANCE hInstance);
BOOL                InitInstance(HINSTANCE, int);
LRESULT CALLBACK    WndProc(HWND, UINT, WPARAM, LPARAM);
INT_PTR CALLBACK    About(HWND, UINT, WPARAM, LPARAM);
DWORD Posled(LPVOID);
DWORD Koll(LPVOID);
DWORD Fib(LPVOID);
 
int APIENTRY _tWinMain(_In_ HINSTANCE hInstance,
                     _In_opt_ HINSTANCE hPrevInstance,
                     _In_ LPTSTR    lpCmdLine,
                     _In_ int       nCmdShow)
{
    UNREFERENCED_PARAMETER(hPrevInstance);
    UNREFERENCED_PARAMETER(lpCmdLine);
 
    // TODO: разместите код здесь.
    MSG msg;
    HACCEL hAccelTable;
 
 
    // Инициализация глобальных строк
    LoadString(hInstance, IDS_APP_TITLE, szTitle, MAX_LOADSTRING);
    LoadString(hInstance, IDC_KURSS, szWindowClass, MAX_LOADSTRING);
    MyRegisterClass(hInstance);
 
    // Выполнить инициализацию приложения:
    if (!InitInstance (hInstance, nCmdShow))
    {
        return FALSE;
    }
 
 
    hAccelTable = LoadAccelerators(hInstance, MAKEINTRESOURCE(IDC_KURSS));
 
 
    // Цикл основного сообщения:
    while (GetMessage(&msg, NULL, 0, 0))
    {
        if (!TranslateAccelerator(msg.hwnd, hAccelTable, &msg))
        {
            TranslateMessage(&msg);
            DispatchMessage(&msg);
        }
    }
 
    
 
    return (int) msg.wParam;
}
 
 
 
//
//  ФУНКЦИЯ: MyRegisterClass()
//
//  НАЗНАЧЕНИЕ: регистрирует класс окна.
//
ATOM MyRegisterClass(HINSTANCE hInstance)
{
    WNDCLASSEX wcex;
 
    wcex.cbSize = sizeof(WNDCLASSEX);
 
    wcex.style          = CS_HREDRAW | CS_VREDRAW;
    wcex.lpfnWndProc    = WndProc;
    wcex.cbClsExtra     = 0;
    wcex.cbWndExtra     = 0;
    wcex.hInstance      = hInstance;
    wcex.hIcon          = LoadIcon(hInstance, MAKEINTRESOURCE(IDI_KURSS));
    wcex.hCursor        = LoadCursor(NULL, IDC_ARROW);
    wcex.hbrBackground  = (HBRUSH)(COLOR_WINDOW+1);
    wcex.lpszMenuName   = MAKEINTRESOURCE(IDC_KURSS);
    wcex.lpszClassName  = szWindowClass;
    wcex.hIconSm        = LoadIcon(wcex.hInstance, MAKEINTRESOURCE(IDI_SMALL));
 
    return RegisterClassEx(&wcex);
}
 
//
//   ФУНКЦИЯ: InitInstance(HINSTANCE, int)
//
//   НАЗНАЧЕНИЕ: сохраняет обработку экземпляра и создает главное окно.
//
//   КОММЕНТАРИИ:
//
//        В данной функции дескриптор экземпляра сохраняется в глобальной переменной, а также
//        создается и выводится на экран главное окно программы.
//
BOOL InitInstance(HINSTANCE hInstance, int nCmdShow)
{
 
   hInst = hInstance; // Сохранить дескриптор экземпляра в глобальной переменной
 
   hWnd = CreateWindow(szWindowClass, szTitle, WS_OVERLAPPEDWINDOW,
      CW_USEDEFAULT, 0, CW_USEDEFAULT, 0, NULL, NULL, hInstance, NULL);
 
 
   if (!hWnd)
   {
      return FALSE;
   }
 
   ShowWindow(hWnd, nCmdShow);
   UpdateWindow(hWnd);
 
 
 
   return TRUE;
}
 
//
//  ФУНКЦИЯ: WndProc(HWND, UINT, WPARAM, LPARAM)
//
//  НАЗНАЧЕНИЕ:  обрабатывает сообщения в главном окне.
//
//  WM_COMMAND  - обработка меню приложения
//  WM_PAINT    -Закрасить главное окно
//  WM_DESTROY   - ввести сообщение о выходе и вернуться.
//
//
LRESULT CALLBACK WndProc(HWND hWnd, UINT message, WPARAM wParam, LPARAM lParam)
{
    int wmId, wmEvent;
    PAINTSTRUCT ps;
 
    switch (message)
    {
    case WM_SIZE:
        x=LOWORD(lParam);
        y=HIWORD(lParam);
        break;
    case WM_INITDIALOG:
        return TRUE;
        break;
    case WM_CREATE:
        //static1=CreateWindow(L"static", L"Возростающая последовательность:", WS_VISIBLE|WS_CHILD, 25, 100, 250, 
        //  30, hWnd, NULL, ((LPCREATESTRUCT) lParam)->hInstance, NULL);
        
        break;
    case WM_COMMAND:
        wmId    = LOWORD(wParam);
        wmEvent = HIWORD(wParam);
        // Разобрать выбор в меню:
        switch (wmId)
        {
        case IDM_ABOUT:
            DialogBox(hInst, MAKEINTRESOURCE(IDD_ABOUTBOX), hWnd, About);
            break;
        case IDM_EXIT:
            DestroyWindow(hWnd);
            break;
        default:
            return DefWindowProc(hWnd, message, wParam, lParam);
        }
        break;
    case WM_PAINT:
        hdc = BeginPaint(hWnd, &ps);
        GetClientRect(hWnd, &crect);
        MoveToEx(hdc,x/2,0, NULL);
        LineTo(hdc,x/2,y);
        MoveToEx(hdc,0,y/2,NULL);
        LineTo(hdc,x,y/2);
        hTh[0]=CreateThread(0, NULL, (LPTHREAD_START_ROUTINE) Posled, NULL, NULL, dwTh[0]);
        hTh[3]=CreateThread(0, NULL, (LPTHREAD_START_ROUTINE) Koll, NULL, NULL, dwTh[3]);
        hTh[1]=CreateThread(0, NULL, (LPTHREAD_START_ROUTINE) Fib, NULL, NULL, dwTh[1]);
          WaitForSingleObject(hTh[0], INFINITE);
        //WaitForSingleObject(hTh[3], INFINITE);
        // TODO: добавьте любой код отрисовки...
        EndPaint(hWnd, &ps);
        break;
    case WM_DESTROY:
        TerminateThread(hTh[0], 1);
        TerminateThread(hTh[1], 1);
        //TerminateThread(hTh[2], 1);
        TerminateThread(hTh[3], 1);
        PostQuitMessage(0);
        break;
    default:
        return DefWindowProc(hWnd, message, wParam, lParam);
    }
 
    return 0;
}
 
// Обработчик сообщений для окна "О программе".
INT_PTR CALLBACK About(HWND hDlg, UINT message, WPARAM wParam, LPARAM lParam)
{
    UNREFERENCED_PARAMETER(lParam);
    switch (message)
    {
    case WM_INITDIALOG:
        return (INT_PTR)TRUE;
 
    case WM_COMMAND:
        if (LOWORD(wParam) == IDOK || LOWORD(wParam) == IDCANCEL)
        {
            EndDialog(hDlg, LOWORD(wParam));
            return (INT_PTR)TRUE;
        }
        break;
    }
    return (INT_PTR)FALSE;
}
 
DWORD Posled(LPVOID lPar){
    n[0]++;
    char s[]="Возрастающая последовательность: ";
for(int i=1;i<11;i++){
            char c[10];
            _itoa_s(i, c, 10);
            TextOutA(hdc, 100,100, s, strlen(s));
            TextOutA(hdc, 350,100, c, strlen(c));
            Sleep(2000);
            InvalidateRect(hWnd, NULL, TRUE);
        }
return 0;
}
 
DWORD Koll(LPVOID lPar){
        //WaitForSingleObject(hTh[1], INFINITE);
    char count1[10], count2[10], count3[10];
    char s1[]="№ запусков 1-го потока:";
    char s2[]="№ запусков 2-го потока:";
    char s3[]="№ запусков 3-го потока:";
    _itoa_s(n[0], count1, 10);
    _itoa_s(n[1], count2, 10);
    _itoa_s(n[2], count3, 10);
    
    TextOutA(hdc, x/2+10,y/2+10, s1, strlen(s1));
    TextOutA(hdc, x/2+172, y/2+10, count1, strlen(count1));
 
    TextOutA(hdc, x/2+10,y/2+30, s2, strlen(s2));
    TextOutA(hdc, x/2+172, y/2+30, count2, strlen(count1));
 
    TextOutA(hdc, x/2+10,y/2+50, s3, strlen(s3));
    TextOutA(hdc, x/2+172, y/2+50, count3, strlen(count1));
    
    //WaitForSingleObject(hTh[0],INFINITE);
    return 0;
}
 
DWORD Fib(LPVOID lPae){
    n[1]++;
    char s[]="Числа Фибоначчи: ";
int fib1 = 1, fib2 = 1, fib_sum;
int i = 2; 
while (i < 10){
    char c[10];
    fib_sum = fib2 + fib1;
    fib1 = fib2;
    fib2 = fib_sum;
    i += 1;
    _itoa_s(fib_sum, c, 10);
    TextOutA(hdc, x/2+50,y/2-300, s, strlen(s));
    TextOutA(hdc, x/2+180,y/2-300, c, strlen(c));
    Sleep(1000);
}
return 0;
}
Возможно, нужно их не в WM_Paint -е запускать; пробовал в Main и WM_CREATE - сначала выполняется полностью поток, а потом открывается окно.
0
Лучшие ответы (1)
Programming
Эксперт
94731 / 64177 / 26122
Регистрация: 12.04.2006
Сообщений: 116,782
17.05.2015, 13:07
Ответы с готовыми решениями:

Синхронизация потоков
Здравствуйте, уважаемые форумчане! Нужно мне написать прогу на синхронизацию. Задача такая: есть...

Синхронизация потоков
в общем есть код: DWORD WINAPI IndexSystemFile::GetFileFromDrive(void *DriveName){...

Синхронизация потоков
Добрый день. Помогите пожалуйста написать программу на С++ по синхронизации потоков. Задание такое:...

Синхронизация потоков
Как переделать с использованием mutex или еще чего нибудь? /*Три нити. Одна генерирует...

24
0 / 0 / 0
Регистрация: 17.05.2015
Сообщений: 15
24.05.2015, 17:47  [ТС] 21
Author24 — интернет-сервис помощи студентам
Цитата Сообщение от jonson Посмотреть сообщение
Вот потому и не вижу смысла в таком бессмысленном злоупотребление ресурсами. Создание потока это не просто вызов функции. И в твоем случае этот подход абсолютно не оправдан.
не моя инициатива - задание такое.
Цитата Сообщение от jonson Посмотреть сообщение
Все потому, что при каждом новом выполнении нет данных о старых координатах, по которым нужно "затереть" старый прямоугольник.
Без заливки они пропадали до этого. Может попробовать координаты как static int объявить?

Добавлено через 5 минут
Цитата Сообщение от jonson Посмотреть сообщение
Все потому, что при каждом новом выполнении нет данных о старых координатах, по которым нужно "затереть" старый прямоугольник.
Почему же?
C++
1
2
3
4
5
6
7
8
9
10
srand(time(NULL));
xLeft=2+rand()%(x/2);
xRight=2+rand()%(x/2);
yTop=2+rand()%(y/2)+y/2;
yBottom=2+rand()%(y/2)+y/2;
SetRect(&rect, xLeft, yTop, xRight, yBottom);
FillRect(hdc, &rect, hbrush);
Sleep(1000);
FillRect(hdc, &rect, (HBRUSH)GetStockObject(DKGRAY_BRUSH));
Sleep(1000);
Разве в таком случае не должно через секунду залить "безцветным" цветом, а еще через секунду только завершение потока?
0
240 / 213 / 84
Регистрация: 18.03.2010
Сообщений: 750
24.05.2015, 17:56 22
Цитата Сообщение от Alex Logan Посмотреть сообщение
Может попробовать координаты как static int объявить?
ну тут варианта 2, либо статические, либо глобальные.

Добавлено через 8 минут
Цитата Сообщение от Alex Logan Посмотреть сообщение
Разве в таком случае не должно через секунду залить "безцветным" цветом, а еще через секунду только завершение потока?
В таком должно. В посте 19 у тебя строка 25 закоменчена.
Цитата Сообщение от Alex Logan Посмотреть сообщение
а еще через секунду только завершение потока?
не пойму зачем поток должен ждать секунду..
0
0 / 0 / 0
Регистрация: 17.05.2015
Сообщений: 15
24.05.2015, 18:07  [ТС] 23
Цитата Сообщение от jonson Посмотреть сообщение
не пойму зачем поток должен ждать секунду..
Что бы точно увидеть результат.
Цитата Сообщение от jonson Посмотреть сообщение
В таком должно.
Почему же тогда не происходит?
Еще статически их объявил - тоже не помогает..
0
240 / 213 / 84
Регистрация: 18.03.2010
Сообщений: 750
24.05.2015, 18:29 24
Цитата Сообщение от Alex Logan Посмотреть сообщение
Еще статически их объявил
это не требуется, ты же после отрисовки прямоугольника решил его "затереть" по тем же координатам.
Цитата Сообщение от Alex Logan Посмотреть сообщение
Почему же тогда не происходит?
все должно работать.
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
// получаем случайные координаты
// ...
// ...
 
SetRect(&crect, xLeft, yTop, xRight, yBottom);
    
hdc = GetDC(wnd);
FillRect(hdc, &crect, hbrush); 
ReleaseDC(wnd, hdc);
InvalidateRect(wnd, &crect, false); 
    
Sleep(1000);
 
hdc = GetDC(wnd);
FillRect(hdc, &crect, (HBRUSH)GetStockObject(DKGRAY_BRUSH)); 
ReleaseDC(wnd, hdc);
InvalidateRect(wnd, &crect, false);
1
0 / 0 / 0
Регистрация: 17.05.2015
Сообщений: 15
24.05.2015, 18:57  [ТС] 25
jonson, так работает.
Почему в одном GetDC() - ReleaseDC() не работает? А с двумя отдельными работает. Суть ведь не меняется. Странно это.. В любом случае, спасибо.
0
24.05.2015, 18:57
IT_Exp
Эксперт
87844 / 49110 / 22898
Регистрация: 17.06.2006
Сообщений: 92,604
24.05.2015, 18:57
Помогаю со студенческими работами здесь

Синхронизация потоков
Нужно: Выполнение нескольких арифметических операций разного приоритета. Оперировать с помощью...

Синхронизация потоков
Вот код: #include &quot;iostream&quot; #include &quot;windows.h&quot; using namespace std; char*...

Синхронизация потоков
Здравствуйте. Подскажите пожалуйста. У меня есть три потока. Мне нужно чтобы они запускались...

Синхронизация потоков
Помогите обеспечить синхронизацию потоков const int j=20; hSemaphore = CreateSemaphore(NULL,...


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

Или воспользуйтесь поиском по форуму:
25
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2024, CyberForum.ru