Добавить многопоточность

@163RUSland · Регистрация: 15.06.2015

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

Доброго времени суток! Собрал кое-какой проект (VS 2008, для работы под windows), хочу добавить туда многопоточность, написал кое-что для теста, главный поток отрабатывает нормально:

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
#include <iostream>
#include <fstream>
#include <windows.h>
using namespace std;
 
char ip[14];
char text[256]={};
 
HANDLE logFile;
DWORD WrittenSize;
DWORD dwSize = sizeof(text);
 
void ThreadFunc(fstream &IP)
{
    logFile = CreateFileA("log.txt", GENERIC_WRITE, FILE_SHARE_READ, NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
    while (!IP.eof()){
        IP >> ip;
        wsprintfA(text, "%s%s", ip, "\r\n");
        SetFilePointer(logFile, 0, NULL, FILE_END);WriteFile(logFile, text, lstrlenA(text), &WrittenSize, NULL);
    }
}
 
int main()
{   
    fstream IP;
    IP.open("ips.txt");
    ThreadFunc(IP);
    IP.close();
    CloseHandle(logFile);
    system("pause");
}[/CODE][/SPOILER]
 
Пытаюсь запустить ThreadFunc() с помощью CreateThread, делаю примерно так:
[CODE]#include <process.h>
#include <iostream>
#include <fstream>
#include <windows.h>
using namespace std;
 
char ip[14];
char text[256]={};
CRITICAL_SECTION cs, cs1;
 
HANDLE logFile;
DWORD WrittenSize;
DWORD dwSize = sizeof(text);
 
DWORD ThreadId;
HANDLE hThread;
 
DWORD WINAPI ThreadFunc(LPVOID lpParametr)
{
    logFile = CreateFileA("log.txt", GENERIC_WRITE, FILE_SHARE_READ, NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
    InitializeCriticalSection (&cs), InitializeCriticalSection (&cs1);
    while (!IP.eof()){
        EnterCriticalSection( &cs );
        IP >> ip;
        LeaveCriticalSection( &cs );
        wsprintfA(text, "%s%s", ip, "\r\n");
        EnterCriticalSection( &cs1 );
        SetFilePointer(logFile, 0, NULL, FILE_END);WriteFile(logFile, text, lstrlenA(text), &WrittenSize, NULL);
        LeaveCriticalSection( &cs1 );
    }
    DeleteCriticalSection (&cs), (&cs1);
}
 
int main()
{   
    fstream IP;
    IP.open("ips.txt");
    hThread = CreateThread(NULL, 0, ThreadFunc, &IP, 0, &ThreadId);
    WaitForSingleObject(hThread, INFINITE);
    CloseHandle(hThread);
    //ThreadFunc(IP);// вместо ThreadFunc(IP) вставить createthread
    IP.close();
    CloseHandle(logFile);
    system("pause");
}

Получаю:
error C2065: 'IP' : undeclared identifier
error C2228: left of '.eof' must have class/struct/union

Подозреваю, что не правильно передаю массив строк IP и не могу сообразить, как передать его внутрь потоковой функции, уважаемые, подскажите, как это должно выглядеть?

@castaway · 27.06.2015, 11:09

Тогда предлагаю для начала:
* ограничить количество введённых с клавиатуры потоков до MAXIMUM_WAIT_OBJECTS или до количества IP-адресов если их меньше MAXIMUM_WAIT_OBJECTS (причина)
* вынести работу с сокетами и выводом в лог и на экран в отдельные функции, причина - сложно разобраться в коде
* дать всем переменным и функциям осмысленные имена, причина - сложно разобраться в коде
* не использовать вторую критическую секцию, если можно легко обойтись одной
* начать всё с начала

Зачем усложнять такие вещи:

C++
1
wsprintfA(text1, "%s%s%s%s%s", ip, "[bad size of answer]", "Response:", text, "\r\n");

если можно проще:

C++
1
wsprintfA( text1, "%s [bad size of answer] Response: %s\n", ip, text );

+ из описания wsprintfA:

Note Do not use. Consider using one of the following functions instead: StringCbPrintf, StringCbPrintfEx, StringCchPrintf, or StringCchPrintfEx. See Security Considerations.

@163RUSland · 27.06.2015, 14:54 **[ТС]**

castaway, проблема возникла из-за банальной невнимательности, не в том месте был closesocket(pop); надо было поместить внутрь цикла, таким образом сокеты создавались (не закрываясь) до тех пор, пока не заполняли всё место ( порядка 17к сокетов), к тому же пока искал проблему убрал с пол десятка варнингов, сейчас это выглядит так, мб кому-то пригодится:

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
#include "stdafx.h"
#define WIN32_LEAN_AND_MEAN
#include <windows.h>
#include <iostream>
#include <fstream>
#include <vector>
#include <string>
#include "winsock2.h"
 
using namespace std;
 
char text[256]={};
char text1[256]={};
unsigned int a = 0;
 
CRITICAL_SECTION cs, cs1;
 
HANDLE logFile;
DWORD WrittenSize;
DWORD dwSize = sizeof(text);
 
DWORD WINAPI ThreadFunc(LPVOID lpParametr)
{   
    vector<string> * ips = (vector<string> *)lpParametr;
    char ip[16];
    short res;
    SOCKET pop;
    struct sockaddr_in addr;
    addr.sin_family = AF_INET;
    addr.sin_port = htons(110);
    
    bool end = 0;
    EnterCriticalSection( &cs );
    if ( a >= ips->size()-3 ) end = 1;
    LeaveCriticalSection( &cs );
    if (end) return 1;
    for (  ; ;  ){
        EnterCriticalSection( &cs );
        if ( a >= ips->size()-3 ) end = 1;
        LeaveCriticalSection( &cs );
        if (end) break;
        EnterCriticalSection( &cs );
        string ip2 = ( *ips )[a];
        strcpy_s( ip, ip2.c_str() );
        a++;
        LeaveCriticalSection( &cs );
        pop = socket(AF_INET, SOCK_STREAM, 0);
        if(pop == INVALID_SOCKET)
        {
            EnterCriticalSection( &cs );
            cout << "Invalid socket\n";
            wsprintfA(text, "%s%s%s", ip, "_Invalid socket", "\r\n");
            WriteFile(logFile, text, lstrlenA(text), &WrittenSize, NULL);
            memset(text, 0, sizeof(text));
            LeaveCriticalSection( &cs );
            closesocket(pop);
            continue;
        }
        addr.sin_addr.s_addr = inet_addr(ip);
 
        BOOL l = TRUE;
        ioctlsocket (pop, FIONBIO, (unsigned long* ) &l);
 
        fd_set read_s;
        timeval time_out;
        FD_ZERO(&read_s);
        FD_SET(pop, &read_s);
        time_out.tv_sec = 3;
        time_out.tv_usec = 0;
 
        connect(pop, (sockaddr *) &addr, sizeof (addr));
        res = select(0, &read_s, NULL, NULL, &time_out);
        if (res <= 0){
            EnterCriticalSection( &cs1 );
            cout << ip << " CONNECTION ERROR\n";
            wsprintfA(text, "%s%s%s", ip, "[ERROR in connect or connection timeout]", "\r\n");
            WriteFile(logFile, text, lstrlenA(text), &WrittenSize, NULL);
            memset(text, 0, sizeof(text));
            LeaveCriticalSection( &cs1 );
            closesocket(pop);
            continue;
        } 
        if (res > 0){
            EnterCriticalSection( &cs1 );
            cout<< ip << " ";
            recv(pop, text, (sizeof(text)-1), 0);
            cout << "response size:" << strlen(text) << " " << text << "\n";
            LeaveCriticalSection( &cs1 );
            if (strlen(text) > 250 || strlen(text) < 3) {
                EnterCriticalSection( &cs1 );
                wsprintfA(text1, "%s%s%s%s%s", ip, "[bad size of answer]", "Response:", text, "\n");
                WriteFile(logFile, text1, lstrlenA(text1), &WrittenSize, NULL);
                memset(text, 0, sizeof(text));
                LeaveCriticalSection( &cs1 );
                closesocket(pop);
                continue;
            }
            EnterCriticalSection( &cs1 );
            wsprintfA(text1, "%s%s%s%s", ip, " ", text, "\n");
            WriteFile(logFile, text1, lstrlenA(text1), &WrittenSize, NULL);
            memset(text, 0, sizeof(text));
            LeaveCriticalSection( &cs1 );
        }
 
        //wsprintfA(text, "%s", "quit\r\n");
        send(pop, "quit\r\n", strlen(text), 0); 
        closesocket(pop);
        }
    return 0;
}
 
int main()
{   
    unsigned int threads_number;
    cout << "amount? ";
    cin >> threads_number;
    vector <string> ips;
    fstream fs_ips;
    fs_ips.open( "ips.txt" );
    while ( !fs_ips.eof() ) {
        char ip2[16];
        fs_ips >> ip2;
        ips.push_back( ip2 );
    }
    fs_ips.close();
    WSADATA wsaData;
    short err;
    err = WSAStartup(MAKEWORD(2,2), &wsaData);
    if(err != 0)
    {
        cout<<"WSAStartup Error: "<<err<<"\n";
        wsprintfA(text, "%s%s%s", "_WSAStartup error: ", err, "\r\n");
        WriteFile(logFile, text, lstrlenA(text), &WrittenSize, NULL);
        memset(text, 0, sizeof(text));
        return 1;
    }
    HANDLE * p_hThreads = new HANDLE [threads_number];
    if ( threads_number > ips.size() ) threads_number = ips.size();
    logFile = CreateFileA("log.txt", GENERIC_WRITE, FILE_SHARE_READ, NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
    InitializeCriticalSection (&cs);
    InitializeCriticalSection (&cs1);
    for(unsigned int i = 0; i < threads_number; i++)
    {
        p_hThreads[i] = CreateThread(NULL, 0, ThreadFunc, &ips, 0, NULL);
    }
    bool end2 = 0;
 
    for (  ; ; ){
        Sleep(3000);
        EnterCriticalSection( &cs );
        if ( a >=  ips.size()-3 ) end2 = 1;
        LeaveCriticalSection( &cs );
        if (end2) {
            Sleep(5000);
            break;}
    }
    for(unsigned int i = 0; i < threads_number; i++)
    {
        CloseHandle(p_hThreads[i]);
    }
    WSACleanup();
    DeleteCriticalSection (&cs);
    DeleteCriticalSection (&cs1);
    CloseHandle(logFile);
    system("pause");
}

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

@castaway · 27.06.2015, 14:58

Сообщение от 163RUSland

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

Верно.

Новые блоги и статьи Все статьи Все блоги /
GitHub Copilot в JetBrains: модель по умолчанию, Fix и контроль MCP and_y87 12.10.2026 10 октября 2026 года GitHub обновил Copilot для JetBrains: добавил настройки стартовой модели, исправления из диагностики и управление автозапуском MCP. Поддержка IDE 2025. 1 прекращена — требуется. . .	GitHub Copilot в JetBrains: модель по умолчанию, Fix и контроль MCP and_y87 12.10.2026 10 октября 2026 года GitHub обновил Copilot для JetBrains: добавил настройки стартовой модели, исправления из диагностики и управление автозапуском MCP. Поддержка IDE 2025. 1 прекращена — требуется. . .	День 5 из 28: Codex подсказывает следующий запрос and_y87 12.10.2026 9 октября 2026 года OpenAI запустила бету Composer predictions — подсказок следующего сообщения в текущем диалоге Codex. Это помощь с формулировкой запроса, а не автоматическое продолжение задачи. . . .	Запустил конкурс "тем и промптов для текстовых квестов созданных почти чисто ИИ" Adler 06.10.2026 Всем привет! За последние три-четыре дня я создал более 16 текстовых квестовых игр используя преимущественно по одному запросу к ИИ на игру. Мне так понравилось смотреть все ветки/ сцены во всех. . .
ИИ не может найти нужный язык в списке Supersumestria 05.10.2026 Я ему даю вот такое изображение и прошу найти и подчеркнуть немецкий язык. Возвращает он вот это: https:/ / i. **********/ vqBWLe2. png Нужную строчку в 3й колонке просто выдумал. . Это. . .	Новая последняя моя музыка в SUNO zorxor 05.10.2026 Здравствуйте, дорогие мои друзья! С большой радостью я хотел бы представить вам свою новую последнею музыку, которую сгенерировала мне по моей просьбе нейросеть SUNO. С уважением, zorxor. Это. . .	Программный домашний кинотеатр russiannick 27.09.2026 Сподобился на программный домашний кинотеатр. В качестве ЯВУ по традиции выбрал js. В помощники взял Яндекс-Алису. Было создано три зала на разные интересы. исторические и ретро сериал Хичкок. . .	Беседа с ИИ о программистах, недопускающих к созданию и правке кода генеративные ИИ и причины этого zorxor 21.09.2026 Раньше я радовался или получал некоторые эмоции, пусть небольшие, но всё же, от самого процесса написания кода, рекомпиляции и запуска, видя постепенное развитие программы и прочее. А теперь лень. . .