Помогите пожалуйста, никак не могу сделать этот рекурсивный обход с многопоточностью. Вон пытался 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
| #include <windows.h>
#include <tchar.h>
#include <stdio.h>
#include <conio.h>
#include <iostream>
#include <cstdlib>
#include <vector>
#include <iostream>
#include <thread>
#include <mutex>
using namespace std;
std::vector<std::wstring> strList;
std::recursive_mutex mtx;
std::mutex mt;
int file = 0;
typedef struct
{
LPCWSTR path;
int numb;
} MsParams_t;
vector<HANDLE> eve;
vector<HANDLE> threads;
int n = 0,stop=0;
std::string convert(LPCTSTR l){
mt.lock();
#ifdef UNICODE // conversion only required in this case
std::string s;
size_t len = _tcslen(l) + 1;
char* buf = new char[len]; // allocate temp. buffer
wcstombs(buf, l, len); // do the conversion
s = buf; // assign to 'std::string'
delete[] buf; // clean up
#else
s = l; // not UNICODE, just assign it
#endif
mt.unlock();
return s;
}
clock_t t0;
HANDLE hThr;
DWORD WINAPI directory(void * param){
WIN32_FIND_DATA FindFileData;
MsParams_t * ptr = (MsParams_t *)param;
HANDLE hFind;
hFind = FindFirstFile(ptr->path, &FindFileData);
FindNextFile(hFind, &FindFileData);
while (FindNextFile(hFind, &FindFileData)){
// wcout << FindFileData.cFileName << endl;
if (FindFileData.dwFileAttributes == FILE_ATTRIBUTE_DIRECTORY){
static std::string _dir;
std::string ss = convert(ptr->path);// = narrow(ptr->path);
std::string s = convert(FindFileData.cFileName);//narrow(FindFileData.cFileName);
ss.erase(ss.find('*'), 1);
_dir = ss + s + "\\*";
wchar_t wtext[260];
std::mbstowcs(wtext, _dir.c_str(), strlen(_dir.c_str()) + 1);//Plus null
/* mtx.lock();
if (n < 4)
{
//eve.push_back(CreateEvent(NULL, FALSE, FALSE, L""));
*/
static MsParams_t params;
params.path = wtext;
params.numb = n;
threads.push_back(CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)directory, (void*)¶ms, 0, NULL));
//thread tr((void*)¶ms);
//events.push_back(CreateEvent(NULL, FALSE, FALSE, L""));
//threads.push_back(/*move(th));//*/
//thread(directory, wtext,n));
cout << "thread add" << endl;
//n++;
//}
/*else{
static MsParams_t params;
params.numb = ptr->numb;
params.path = wtext;
directory((void*)¶ms);
}*/
//LeaveCriticalSection(&cs);
//mtx.unlock();
}
else{
std::string s = narrow(FindFileData.cFileName);
int i=s.find_last_of('.');
std::string ss="";
for (i; i < s.length(); i++)
ss += s[i];
if (ss == ".txt"){
file++;
// cout << file;
}
}
}
if (ptr->numb > -1){
SetEvent(eve[ptr->numb]);
//cout << "set" << endl;
stop++;
}
FindClose(hFind);
//cout << "thread stopped" << endl;
//CloseHandle(threads[ptr->numb]);
return 0;
}
void main()
{
// thread tt(del);
static MsParams_t params;
setlocale(LC_CTYPE, "Russian");
char st[] = "E:\\start\\*";
wchar_t wtext[20];
std::mbstowcs(wtext, st, strlen(st) + 1);//Plus null
LPWSTR ptr = wtext;
t0 = clock();
//hThr = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)directory, (void*)¶ms, 0, NULL);
params.path = ptr;
params.numb = -1;
directory((void*)¶ms);
/*for (int j = 0; j < eve.size(); j++){
WaitForSingleObject(eve[j], INFINITE);
CloseHandle(threads[j]);
cout << "event stop"<< endl;
}*/
while (stop == 3);//уже в тупую не ожидал завершения события, просто накапливал переменную
//for (int i = 0; i < 4; i++){
// threads[i].join();
// cout << "thread stopped" << endl;
//}
clock_t t1 = clock();
cout << "time: " << (double)(t1 - t0) / CLOCKS_PER_SEC << endl;
cout << file<<endl;
_getch();
} |
|
и 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
| #include <windows.h>
#include <tchar.h>
#include <stdio.h>
#include <conio.h>
#include <iostream>
#include <cstdlib>
#include <vector>
#include <iostream>
#include <thread>
#include <mutex>
using namespace std;
std::vector<std::wstring> strList;
std::recursive_mutex mtx;
std::mutex mt;
int file = 0;
typedef struct
{
LPCWSTR path;
int numb;
} MsParams_t;
inline std::string narrow(std::wstring const& text)
{
std::locale const loc("Russian");
wchar_t const* from = text.c_str();
std::size_t const len = text.size();
std::vector<char> buffer(len + 1);
std::use_facet<std::ctype<wchar_t> >(loc).narrow(from, from + len, '_', &buffer[0]);
return std::string(&buffer[0], &buffer[len]);
}
vector<HANDLE> eve;
vector<HANDLE> threads;
int n = 0,stop=0;
std::string convert(LPCTSTR l){
mt.lock();
#ifdef UNICODE // conversion only required in this case
std::string s;
size_t len = _tcslen(l) + 1;
char* buf = new char[len]; // allocate temp. buffer
wcstombs(buf, l, len); // do the conversion
s = buf; // assign to 'std::string'
delete[] buf; // clean up
#else
s = l; // not UNICODE, just assign it
#endif
mt.unlock();
return s;
}
void directory1(MsParams_t ptr){
WIN32_FIND_DATA FindFileData;
HANDLE hFind;
hFind = FindFirstFile(ptr.path, &FindFileData);
FindNextFile(hFind, &FindFileData);
while (FindNextFile(hFind, &FindFileData)){
// wcout << FindFileData.cFileName << endl;
if (FindFileData.dwFileAttributes == FILE_ATTRIBUTE_DIRECTORY){
static std::string _dir;
std::string ss = convert(ptr.path);// = narrow(ptr->path);
std::string s = convert(FindFileData.cFileName);//narrow(FindFileData.cFileName);
ss.erase(ss.find('*'), 1);
_dir = ss + s + "\\*";
wchar_t wtext[260];
std::mbstowcs(wtext, _dir.c_str(), strlen(_dir.c_str()) + 1);//Plus null
mtx.lock();
if (n < 4)
{
static MsParams_t params;
params.path = wtext;
params.numb = n;
thread tr(directory1,params);
cout << "thread add" << endl;
n++;
}
else{
static MsParams_t params;
params.path=wtext;
params.numb = ptr.numb;
directory1(params);
}
mtx.unlock();
}
else{
std::string s = narrow(FindFileData.cFileName);
int i = s.find_last_of('.');
std::string ss = "";
for (i; i < s.length(); i++)
ss += s[i];
if (ss == ".txt"){
file++;
}
}
}
if (ptr.numb > -1){
stop++;
}
FindClose(hFind);
}
clock_t t0;
HANDLE hThr;
void main()
{
// thread tt(del);
static MsParams_t params;
setlocale(LC_CTYPE, "Russian");
char st[] = "E:\\start\\*";
wchar_t wtext[20];
std::mbstowcs(wtext, st, strlen(st) + 1);//Plus null
LPWSTR ptr = wtext;
t0 = clock();
//hThr = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)directory, (void*)¶ms, 0, NULL);
params.path = ptr;
params.numb = -1;
directory1(params);
/*for (int j = 0; j < eve.size(); j++){
WaitForSingleObject(eve[j], INFINITE);
CloseHandle(threads[j]);
cout << "event stop"<< endl;
}*/
while (stop == 3);
//for (int i = 0; i < 4; i++){
// threads[i].join();
// cout << "thread stopped" << endl;
//}
clock_t t1 = clock();
cout << "time: " << (double)(t1 - t0) / CLOCKS_PER_SEC << endl;
cout << file<<endl;
_getch();
} |
|
Всеравно не выходит, так функция работает, проверял, все хорошо. А в многопоточном то 1 поток не запускается то ошибки в строках, вообщем точной ошибки я не видел, ну и ни разу не работало все хорошо. Помогите с этой бедой, заранее спасибо.
Добавлено через 11 минут
Понял что ошибка тут должно быть так , но все равно не работает(
Добавлено через 10 минут
Вобще это реально сделать на чистых ++, писал на дот все отлично работает, тут уже 5 день ковыряюсь? Когда зацикливаю 1 поток, все остальные не работают, тут я так понимаю проблема в приоритетах, предназначен ли чистый С++ для многопоточности?
0
|
(
