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
| #include <iostream>
#include <fstream>
#include <string>
#include <windows.h>
#include<conio.h>
using namespace std;
bool runFirst = true;
HANDLE mutex; //объявление мьютекса
HANDLE console = GetStdHandle(STD_OUTPUT_HANDLE); //объявление консоли
ifstream file;
void Wait(bool first); //ожидание потока
void Run(bool first); // запуск потока
void thread(bool first); // функция потока
//Функция вывода строчек и окрашивание их
//Принимает: true/false для цвета и файл потока
//Возвращает: строки из файла или false, если открыть не удалось
bool line(bool iscolor)
{
string line;
if (!getline(file, line))
return false;
if (iscolor)
{
SetConsoleTextAttribute(console, (WORD)(2)); cout << "Родительский поток: " << line << endl;
}
else
{
SetConsoleTextAttribute(console, (WORD)(4)); cout << "\t\tДочерний поток: " << line << endl;
}
return true;
}
bool empty(ifstream& file)
{
return file.peek() == EOF;
}
DWORD WINAPI process(LPVOID)
{
thread(false);
return 0;
}
int main()
{
setlocale(LC_ALL, "Russian");
file.open("1.txt");
if (!file.is_open())
{
SetConsoleTextAttribute(console, (WORD)(4)); cout << "Файл не найден!" << endl;
SetConsoleTextAttribute(console, (WORD)(7)); system("pause");
return -1;
}
if (empty(file))
{
SetConsoleTextAttribute(console, (WORD)(4)); cout << "Файл пуст" << endl;
SetConsoleTextAttribute(console, (WORD)(7)); system("pause");
return -1;
}
mutex = CreateMutex(0, FALSE, 0);
DWORD dwThreadId;// идентификатор потока
HANDLE threadHandle = CreateThread(NULL, 0, process, NULL, 0, &dwThreadId); //Объявление процесса
thread(true);
WaitForSingleObject(threadHandle, INFINITE);
CloseHandle(threadHandle);
CloseHandle(mutex);
cout << endl;
SetConsoleTextAttribute(console, (WORD)(7)); system("pause");
return 0;
}
void Wait(bool first)
{
WaitForSingleObject(mutex, INFINITE);
while (runFirst != first)
{
ReleaseMutex(mutex);
Sleep(1);
WaitForSingleObject(mutex, INFINITE);
}
}
void Run(bool first)
{
runFirst = first;
ReleaseMutex(mutex);
}
void thread(bool first)
{
int count = (first) ? 2 : 3;
for (;;)
{
Wait(first);
for (int i = 0; i < count; i++)
{
if (!line(first))
{
// если файл закончился, то переключиться на второй поток и завершить текущий
Run(!first);
return;
}
}
Run(!first);
}
} |
(
