Корректное завершение потока без утечки памяти

@skident · Регистрация: 11.12.2011

Студворк — интернет-сервис помощи студентам

Здравствуйте, есть разбирался с многопоточностью и остановился на _beginthreadex.
Суть программы, что надо создать N количество клиентов (у меня пока 2) и один сервер. Клиенты добавляют какую-то информацию в очередь с приоритетом, а сервер их должен будет записывать в файл (у меня пока вывод на экран частичной информации).

Так вот при запуске приложения на 3 потока (2 клиента и 1 сервер) я получаю сначала корректную работу. Если по завершении приложения запустить еще пару раз, то начнут валиться ошибки типа: 1 поток выполнился корректно, а второй клиент уже завершился (запустился) некорректно. Ну и если дальше запускать, то вообще может ниодин поток не запуститься. Я грешу на то, что не завершаю потоки и они висят в памяти.
Погуглив нашел _endthreadex(0);, но по сути абсолютно ничего не меняется в работе программы.

Подскажите, как можно решить данную проблему и вообще корректно ли написаны функции потоков (так как я переписывал пример с какого-то сайта под свои потребности).

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
#include <iostream>
#include <queue>
#include <windows.h>
#include <process.h>
#include <stdio.h>
 
using namespace std;
 
typedef unsigned long DWORD;
 
typedef struct tagTDATA {
    int cPriority;     //приоритет запроса 0 – 255 (0 – наивысший приоритет)
    DWORD dwTicks;     //время формирования запроса в системных тиках
    DWORD dwClientId;  //уникальный идентификатор клиента
    char *Data;        //абстрактные данные
    inline bool operator >(const tagTDATA other) const
    {
        return cPriority > other.cPriority;
    }
    inline bool operator <(const tagTDATA other) const
    {
        return cPriority < other.cPriority;
    }
} TDATA, *PTDATA;
 
DWORD startTickCount = GetTickCount();
 
class Client {
private: 
    static int ID;
    int id;
 
public:
    Client() {
        id = ID;
        ID += 1;
    }
 
    int getId() const {
        return id;
    }
};
 
tagTDATA sendRequest(Client& c) {
        tagTDATA ptr;
        char *chPt = "Client";
        ptr.cPriority =rand() % 255 - 1;
        ptr.dwTicks = GetTickCount() - startTickCount;
        ptr.dwClientId = c.getId();
        ptr.Data = chPt;
 
        return ptr;
}
 
priority_queue<tagTDATA, vector<tagTDATA>, greater<tagTDATA> > myQueue;
 
unsigned __stdcall server(void *a) {
    while(1) {
        while (!myQueue.empty()) {
            cout << myQueue.top().cPriority << " | "; 
            cout << myQueue.top().dwClientId << " | ";
            cout << myQueue.top().Data << " | ";
            cout << myQueue.top().dwTicks << endl;
            
            myQueue.pop();
        }
    }
 
    return 0;
}
 
unsigned __stdcall client(void *c) {
    Client *c1 = static_cast<Client*>(c);
    tagTDATA ptr;
 
    char *chPt = "Client";
    ptr.cPriority = rand() % 255 - 1;
    ptr.dwTicks = GetTickCount() - startTickCount;
    ptr.dwClientId = c1->getId();
    ptr.Data = chPt;
    
    myQueue.push(ptr);
    //_endthreadex(0);
    return 0;
}
 
int Client::ID = 1;
 
int main() {
    HANDLE hThread, hEvent;
    
    hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
    //cout << "Enter number of clients: ";
    //cin >> count;
 
    Client **clArray = new Client*[2];
 
    for ( int i = 0; i < 2; i++ ) {
        Client *cl = new Client;
        clArray[i] = cl;
    }
    
    for ( int i = 0; i < 2; i++ ) {
        _beginthreadex(NULL, 0,  client, clArray[i], 0, 0);
    }
    _beginthreadex(NULL, 0,  server, NULL, 0, 0);
    
    getchar();
 
    return 0;
}

Добавлено через 50 минут
Появилась ошибка, что итератор вышел за границы vector. Понял, что удалил инклуд vector, так как думал, что он мне уже не нужен. Вернул назад, но теперь при запуске получаю
BKS.exe привело в действие точку остановка

Код почти не поменялся, но для ясности сброшу новый вариант

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
#include <iostream>
#include <vector>
#include <queue>
 
#include <windows.h>
#include <process.h>
#include <stdio.h>
 
using namespace std;
 
typedef unsigned long DWORD;
 
typedef struct tagTDATA {
    int cPriority;     //приоритет запроса 0 – 255 (0 – наивысший приоритет)
    DWORD dwTicks;     //время формирования запроса в системных тиках
    DWORD dwClientId;  //уникальный идентификатор клиента
    char *Data;        //абстрактные данные
    inline bool operator >(const tagTDATA other) const
    {
        return cPriority > other.cPriority;
    }
    inline bool operator <(const tagTDATA other) const
    {
        return cPriority < other.cPriority;
    }
} TDATA, *PTDATA;
 
DWORD startTickCount = GetTickCount();
 
class Client {
private: 
    static int ID;
    int id;
 
public:
    Client() {
        id = ID;
        ID += 1;
    }
 
    int getId() const {
        return id;
    }
};
 
tagTDATA sendRequest(Client& c) {
        tagTDATA ptr;
        char *chPt = "Client";
        ptr.cPriority =rand() % 255 - 1;
        ptr.dwTicks = GetTickCount() - startTickCount;
        ptr.dwClientId = c.getId();
        ptr.Data = chPt;
 
        return ptr;
}
 
priority_queue<tagTDATA, vector<tagTDATA>, greater<tagTDATA> > myQueue;
 
unsigned __stdcall server(void *a) {
    //while(1) {
        while (!myQueue.empty()) {
            cout << myQueue.top().cPriority << " | "; 
            cout << myQueue.top().dwClientId << " | ";
            cout << myQueue.top().Data << " | ";
            cout << myQueue.top().dwTicks << endl;
            
            myQueue.pop();
        }
    //}
 
    return 0;
}
 
unsigned __stdcall client(void *c) {
    Client *c1 = static_cast<Client*>(c);
    tagTDATA ptr;
 
    char *chPt = "Client";
    ptr.cPriority = rand() % 255 - 1;
    ptr.dwTicks = GetTickCount() - startTickCount;
    ptr.dwClientId = c1->getId();
    ptr.Data = chPt;
    
    myQueue.push(ptr);
    _endthreadex(0);
    return 0;
}
 
int Client::ID = 1;
 
int main() {
    int count = 10;
    
    //cout << "Enter number of clients: ";
    //cin >> count;
 
    Client **clArray = new Client*[count];
 
    for ( int i = 0; i < count; i++ ) {
        Client *cl = new Client;
        clArray[i] = cl;
    }
    
    for ( int i = 0; i < count; i++ ) {
        _beginthreadex(NULL, 0,  client, clArray[i], 0, 0);
    }
    //_beginthreadex(NULL, 0,  server, NULL, 0, 0);
    
    getchar();
 
    return 0;
}

Убежденный · 10.06.2013, 11:58

В этом коде две проблемы.

Первая заключается в том, что доступ к очереди myQueue не синхронизирован.
Если два или более потока попытаются одновременно читать и писать в очередь,
результат будет непредсказуемым. Объекты STL из Visual C++ потокобезопасны
только на чтение, поэтому здесь следует применять критическую секцию или
другой подходящий примитив синхронизации.

Вторая проблема - логическая.
Суть в том, что поток сервера может запуститься раньше, чем поток клиента.
И тогда он сразу увидит, что очередь пуста, и завершит свою работу.

Явно вызывать _endthreadex для потока, созданного _beginthreadex, не нужно,
так как система сделает это сама при его завершении. А вот закрыть хэндлы
потоков и очистить массив clArray очень желательно, во избежание утечек.

@skident · 10.06.2013, 12:22 **[ТС]**

Про критические секции я где-то читал там вроде все решается двумя строчками.
По поводу закрытия хандлов есть идея. Создавать массив хандлов и так же в цикле их потом закрывать
А вот на счет сервера, прокатит ли использование в данном потоке бесконечного цикла while ? То есть поток будет себе постоянно висеть и проверять данные. Или же можно дождаться выполнения всех клиентов и тогда запустить сервер.

Не подскажите как дождаться выполнения всех потоков!?

Добавлено через 11 минут
О, с критичиской секцией прога работает вроде стабильно.

На счет дождаться выполнения всех клиентов подскажите!?

Убежденный · 10.06.2013, 12:27

Сообщение от skident

Не подскажите как дождаться выполнения всех потоков!?

Потоки могут сами просигналить о готовности, см. функцию SetEvent, например.
На хэндлах потоков можно ждать wait-функциями. Поток завершается - приходит в
сигнальное состояние.

И уберите из кода сервера "while(1)" - это пустое прожигание ресурсов процессора.

@skident · 10.06.2013, 12:35 **[ТС]**

Спасибо большое за доходчивые ответы!!!

Новые блоги и статьи Все статьи Все блоги /
Восстановить юзерскрипты Greasemonkey из бэкапа браузера damix 15.01.2026 Если восстановить из бэкапа профиль Firefox после переустановки винды, то список юзерскриптов в Greasemonkey будет пустым. Но восстановить их можно так. Для этого понадобится консольная утилита. . .	Изучаю kubernetes lagorue 13.01.2026 А пригодятся-ли мне знания kubernetes в России?	Сукцессия микоризы: основная теория в виде двух уравнений. anaschu 11.01.2026 https:/ / rutube. ru/ video/ 7a537f578d808e67a3c6fd818a44a5c4/	WordPad для Windows 11 Jel 10.01.2026 WordPad для Windows 11 — это приложение, которое восстанавливает классический текстовый редактор WordPad в операционной системе Windows 11. После того как Microsoft исключила WordPad из. . .
Classic Notepad for Windows 11 Jel 10.01.2026 Old Classic Notepad for Windows 11 Приложение для Windows 11, позволяющее пользователям вернуть классическую версию текстового редактора «Блокнот» из Windows 10. Программа предоставляет более. . .	Почему дизайн решает? Neotwalker 09.01.2026 В современном мире, где конкуренция за внимание потребителя достигла пика, дизайн становится мощным инструментом для успеха бренда. Это не просто красивый внешний вид продукта или сайта — это. . .	Модель микоризы: классовый агентный подход 3 anaschu 06.01.2026 aa0a7f55b50dd51c5ec569d2d10c54f6/ O1rJuneU_ls https:/ / vkvideo. ru/ video-115721503_456239114	Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR ФедосеевПавел 06.01.2026 Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR ВВЕДЕНИЕ Введу сокращения: аналоговый ПИД — ПИД регулятор с управляющим выходом в виде числа в диапазоне от 0% до. . .

Убежденный Ушел с форума 16481 / 7444 / 1187 Регистрация: 02.05.2013 Сообщений: 11,616 Записей в блоге: 1
	10.06.2013, 11:58
	В этом коде две проблемы. Первая заключается в том, что доступ к очереди myQueue не синхронизирован. Если два или более потока попытаются одновременно читать и писать в очередь, результат будет непредсказуемым. Объекты STL из Visual C++ потокобезопасны только на чтение, поэтому здесь следует применять критическую секцию или другой подходящий примитив синхронизации. Вторая проблема - логическая. Суть в том, что поток сервера может запуститься раньше, чем поток клиента. И тогда он сразу увидит, что очередь пуста, и завершит свою работу. Явно вызывать _endthreadex для потока, созданного _beginthreadex, не нужно, так как система сделает это сама при его завершении. А вот закрыть хэндлы потоков и очистить массив clArray очень желательно, во избежание утечек. 1

@skident 23 / 23 / 6 Регистрация: 11.12.2011 Сообщений: 300
	10.06.2013, 12:22 [ТС]
	Про критические секции я где-то читал там вроде все решается двумя строчками. По поводу закрытия хандлов есть идея. Создавать массив хандлов и так же в цикле их потом закрывать А вот на счет сервера, прокатит ли использование в данном потоке бесконечного цикла while ? То есть поток будет себе постоянно висеть и проверять данные. Или же можно дождаться выполнения всех клиентов и тогда запустить сервер. Не подскажите как дождаться выполнения всех потоков!? Добавлено через 11 минут О, с критичиской секцией прога работает вроде стабильно. На счет дождаться выполнения всех клиентов подскажите!? 0

@skident 23 / 23 / 6 Регистрация: 11.12.2011 Сообщений: 300
	10.06.2013, 12:35 [ТС]
	Спасибо большое за доходчивые ответы!!! 0