Лабораторные работы / Windows лаб 1-4 / lab4_var2_kod
.pdf// ожидание всех потоков
WaitForMultipleObjects(threads_count, threads, TRUE, INFINITE); for (auto h : threads)
CloseHandle(h);
// Удаление КО
DeleteCriticalSection(&csec_r); DeleteCriticalSection(&csec_s); return 0;
}
Пункт 4
#include <cstdio> #include <random> #include <process.h> #include <windows.h>
// Структура узла списка struct Node
{
explicit Node(unsigned x) : value(x)
{} |
|
Node* next = nullptr; |
// следующий узел |
unsigned value = 0; |
// хранимое значение |
};
// Класс списка (очереди на односвязном списке) class Queue
{
public:
Queue() = default; Queue(const Queue&) = delete;
Queue& operator=(const Queue&) = delete;
~Queue()
{// удаление всех узлов очереди while (head) // пока есть узлы
{
auto temp = head; |
// получаем первый узел |
|
head = temp->next; |
// сдвигаем начало очереди на следующий узел |
|
delete temp; |
// удаляем узел |
|
}
}
// Вставка значения в очередь void Push(unsigned x)
{
auto node = new Node(x); // создаем новый узел
if (tail) |
// если очередь непуста |
|
tail->next = node; |
// добавляем в конец |
|
else |
// если очередь пуста |
|
11
head = node; |
// новый узел будет первым в очереди |
tail = node; |
// устанавливаем новый конец |
}
//Извлечение значения из очереди.
//Если очередь непуста, в out_val записывается
//извлекаемое значение и возвращается true.
//Иначе, возвращается false, а out_val не изменяется. bool Pop(unsigned* out_val)
{
if (!head) |
// очередь пуста |
|
return false; |
|
|
*out_val = head->value; // пишем извлекаемое значение |
||
Node* tmp = head; |
// этот узел удалим ниже |
|
head = tmp->next; |
// передвигаем начало очереди на следующий узел |
|
if (!head) |
// если это был последний узел |
|
tail = nullptr; |
// делаем конец пустым |
|
delete tmp; |
|
// удаляем узел с извлеченным значением |
return true; |
|
|
}
private:
Node* head = nullptr; // первый узел Node* tail = nullptr; // последний узел
};
//Очереди, общие для всех потоков
Queue S, R;
//КО для общих очередей
CRITICAL_SECTION csec_s, csec_r;
//Функция потока А
unsigned __stdcall ThreadProcA(void*)
{
unsigned x = 0;
// в цикле добавляем в S значения 1, 2, 3 и т.д. while (true)
{
EnterCriticalSection(&csec_s); // Вход в КО для S S.Push(++x); // добавляем очередное значение в S LeaveCriticalSection(&csec_s); // Выход из КО для S
}
return 0;
} |
|
// Возвращает true с вероятностью 1/10 |
|
bool GetChance() |
|
{ |
|
static std::mt19937 gen(std::random_device{}()); |
// инициализируем генератор случайных чисел |
static std::uniform_int_distribution<int> dist(1, 10); |
// равномерное распределение целых чисел |
return dist(gen) == 1; // значение с вероятностью 1/10
}
12
// Функция потока B
unsigned __stdcall ThreadProcB(void*)
{
while (true)
{
unsigned x;
EnterCriticalSection(&csec_s); // Вход в КО для S
auto extracted = S.Pop(&x); // пытаемся извлечь значение из S LeaveCriticalSection(&csec_s); // Выход из КО для S
if (extracted) |
|
{ |
// если извлекли значение из S |
EnterCriticalSection(&csec_r); // Вход в КО для R |
|
if (GetChance()) |
// с вероятностью 1/10 |
ExitThread(0); |
// завершаем поток |
R.Push(x * x); |
// добавляем его квадрат в R |
LeaveCriticalSection(&csec_r); // Выход из КО для R
}
else // иначе, ждем секунду
Sleep(1000);
}
return 0;
}
// Функция потока C
unsigned __stdcall ThreadProcC(void*)
{
while (true)
{
unsigned x;
EnterCriticalSection(&csec_s); // Вход в КО для S
auto extracted = S.Pop(&x); // пытаемся извлечь значение из S LeaveCriticalSection(&csec_s); // Выход из КО для S
if (extracted) |
|
|
{ // извлекли значение из S |
|
|
EnterCriticalSection(&csec_r); |
// Вход в КО для R |
|
R.Push(x / 3); |
// добавляем в R значение/3 |
|
LeaveCriticalSection(&csec_r); |
// Выход из КО для R |
|
} |
|
|
else // иначе, ждем секунду |
|
|
Sleep(1000); |
|
|
}
return 0;
}
// Функция потока D
unsigned __stdcall ThreadProcD(void*)
{
while (true)
{
unsigned x;
13
EnterCriticalSection(&csec_r); |
// Вход в КО для R |
|
auto extracted = R.Pop(&x); |
// пытаемся извлечь значение из R |
|
LeaveCriticalSection(&csec_r); // Выход из КО для R |
||
if (extracted) |
// если извлекли значение из R |
|
printf("%u\n", x); // печатаем его else
{
}
}
return 0;
}
int main()
{
const size_t threads_count = 4; HANDLE threads[threads_count];
//Инициализация КО
InitializeCriticalSection(&csec_s); InitializeCriticalSection(&csec_r);
//создание потоков
threads[0] = (HANDLE)_beginthreadex(nullptr, 0, ThreadProcA, nullptr, 0, nullptr); threads[1] = (HANDLE)_beginthreadex(nullptr, 0, ThreadProcB, nullptr, 0, nullptr); threads[2] = (HANDLE)_beginthreadex(nullptr, 0, ThreadProcC, nullptr, 0, nullptr); threads[3] = (HANDLE)_beginthreadex(nullptr, 0, ThreadProcD, nullptr, 0, nullptr);
// ожидание всех потоков
WaitForMultipleObjects(threads_count, threads, TRUE, INFINITE); for (auto h : threads)
CloseHandle(h);
// Удаление КО
DeleteCriticalSection(&csec_r); DeleteCriticalSection(&csec_s); return 0;
}
14