Пишу лабораторную, в которой один поток должен передать данные другому в несколько приемов. Передачу осуществляю через файл. Возникла проблема, что на втором цикле считывания из файла, процесс приемник считает, что файл пустой, хотя это не так.
Код отправителя:
| 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
| void __fastcall rthr::Upd()
{Form1->Memo1->Lines->Add(text);}
void __fastcall rthr::Execute()
{
event[0]=CreateEvent(NULL, FALSE, FALSE, "event1");
event[1]=CreateEvent(NULL, FALSE, FALSE, "event2");
event[2]=CreateEvent(NULL, FALSE, FALSE, "terminate");
ifstream in;
ofstream out;
out.open("temp.txt");
text="Поток 1 считывает данные из входного файла";
Synchronize(Upd);
in.open("in.txt");
float q;
int i=0;
while(!in.eof()){
i++;
in>>q;
if(in.eof()){i--; break;}
out<<q+100<<endl;
if(i==1000){
i=0;
out.close();
text="Поток 1 отправляет данные второму потоку";
Synchronize(Upd);
SetEvent(event[0]);
WaitForMultipleObjects(1, &event[1], false, INFINITE);
out.open("temp.txt");
text="Поток 1 считывает данные из входного файла";
Synchronize(Upd);
}
}
if((i!=1000)&&(i!=0)){
out.close();
text="Поток 1 отправляет данные второму потоку";
Synchronize(Upd);
SetEvent(event[0]);
WaitForMultipleObjects(1, &event[1], false, INFINITE);
}
text="Поток 1 завершил пересылку данных";
Synchronize(Upd);
SetEvent(event[2]);
out.close();
in.close();
for(int i=0; i<3; i++)CloseHandle(event[i]);
text="Поток 1 завершил работу";
Synchronize(Upd);
} |
|
Код приемника:
| 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
| void __fastcall wthr::Upd()
{Form1->Memo1->Lines->Add(text);}
void __fastcall wthr::Execute()
{
event[0] = OpenEvent(EVENT_ALL_ACCESS, FALSE, "event1");
event[1]=OpenEvent(EVENT_ALL_ACCESS, FALSE, "event2");
event[2]=OpenEvent(EVENT_ALL_ACCESS, FALSE, "terminate");
HANDLE ev[2]= {event[2], event[0]};
ifstream in1;
ofstream out1;
out1.open("out.txt");
while(true){
int code = WaitForMultipleObjects(2, ev, false, INFINITE);
if(code==WAIT_OBJECT_0)break;
text="Поток 2 принимает данные от первого потока";
Synchronize(Upd);
in1.open("temp.txt");
float q;
while(!in1.eof()){
in1>>q;
if(in1.eof())break;
out1<<q+1000<<endl;
}
text="Поток 2 готов принять следующую порцию данных";
Synchronize(Upd);
in1.close();
SetEvent(event[1]);
}
out1.close();
in1.close();
for(int i=0; i<3; i++)CloseHandle(event[i]);
text="Поток 2 завершил работу";
Synchronize(Upd);
} |
|
Путем прогона по шагам было выяснено, что процесс на втором круге передачи данных не заходит в while на 18ой строчке кода приемника, хотя в то же время при простом открытии файла там обнаруживаются все необходимые данные.
(
