Синхронизация потоков

#include "stdafx.h"
#include <windows.h>
 
// ожидание нового нажатия любой кнопки
void WaitAnyKey()
{
    // хендл ввода
    HANDLE hin = GetStdHandle(STD_INPUT_HANDLE);
 
    // чистим буфер
    FlushConsoleInputBuffer(hin);
 
    // цикл ожидания
    while (true)
    {
        DWORD num;
        INPUT_RECORD rec;
        // ждём события
        WaitForSingleObject(hin, INFINITE);
        // проверяем, что событие соответствует нажатию кнопки
        if (ReadConsoleInput(hin, &rec, 1, &num) && (rec.EventType == KEY_EVENT) && (rec.Event.KeyEvent.bKeyDown))
            break;
    }
}
 
// точка входа
int main()
{
    // подготовка генератора случайных чисел
    srand(GetTickCount());
 
    // создание именованного (межпроцессорного) мьютекса без его блокировки
    HANDLE hMutex = CreateMutex(0, FALSE, TEXT("My Multi Process Mutex"));
 
    // подтверждение запуска
    printf("Writer\r\nPress any key for start and lock\r\n");
    WaitAnyKey();
 
    // пытаемся получить доступ к общему ресурсу (бесконечно долго)
    printf("Wait...");
    DWORD ret = WaitForSingleObject(hMutex, INFINITE);
    printf("done\r\n");
 
    // создаём файл
    FILE* file = fopen("test.txt", "w");
    if (!file)
    {
        // сообщаем об ошибке
        printf("Can't create file 'test.txt'\r\n");
    }
    else
    {
        // записываем 100 случайных чисел от -100 до +100
        for (int i = 0; i < 100; i++)
            fprintf(file, "%0.1f ", ((rand() % 2000) - 1000) / 10.0);
 
        // закрытие файла
        fclose(file);
    }
 
    // подтверждение окончания
    printf("Press any key for finish and unlock\r\n");
    WaitAnyKey();
 
    // освобождение мьютекса, позволяем другому процессу получить доступ к общему ресурсу
    ReleaseMutex(hMutex);
 
    // закрытие мьютекса
    CloseHandle(hMutex);
 
    return 0;
}

#include "stdafx.h"
#include <windows.h>
 
// ожидание нового нажатия любой кнопки
void WaitAnyKey()
{
    // хендл ввода
    HANDLE hin = GetStdHandle(STD_INPUT_HANDLE);
 
    // чистим буфер
    FlushConsoleInputBuffer(hin);
 
    // цикл ожидания
    while (true)
    {
        DWORD num;
        INPUT_RECORD rec;
        // ждём события
        WaitForSingleObject(hin, INFINITE);
        // проверяем, что событие соответствует нажатию кнопки
        if (ReadConsoleInput(hin, &rec, 1, &num) && (rec.EventType == KEY_EVENT) && (rec.Event.KeyEvent.bKeyDown))
            break;
    }
}
 
// структура для потока
struct SThreadData
{
    int cnt;
    double sum;
};
 
// глупый поток вывода результата
DWORD WINAPI MyOutThread(LPVOID ptr)
{
    SThreadData* pData = (SThreadData*)ptr;
 
    // вывод результата
    if (pData)
    {
        printf("count=%d\r\n", pData->cnt);
        if (pData->cnt > 0)
            printf("average=%.2f\r\n", pData->sum / pData->cnt);
    }
 
    return 0;
}
 
// точка входа
int main()
{
    // создание именованного (межпроцессорного) мьютекса без его блокировки
    HANDLE hMutex = CreateMutex(0, FALSE, TEXT("My Multi Process Mutex"));
 
    // подтверждение запуска
    printf("Reader\r\nPress any key for start and lock\r\n");
    WaitAnyKey();
 
    // пытаемся получить доступ к общему ресурсу (бесконечно долго)
    printf("Wait...");
    DWORD ret = WaitForSingleObject(hMutex, INFINITE);
    printf("done\r\n");
 
    // открываем файл
    FILE* file = fopen("test.txt", "r");
    if (!file)
    {
        // сообщаем об ошибке
        printf("Can't open file 'test.txt'\r\n");
    }
    else
    {
        int cnt = 0;
        double num, sum = 0;
 
        // читаем числа и считаем их сумму
        while (fscanf(file, "%lf ", &num) == 1)
        {
            cnt++;
            sum += num;
        }
 
        // вывод результата через поток
        {
            // структура передаваемая потоку
            SThreadData td;
            td.cnt = cnt;
            td.sum = sum;
            // тут будет ID потока
            DWORD id;
            // запуск потока
            HANDLE hThread = CreateThread(0, 0, MyOutThread, &td, 0, &id);
            // ждём пока поток завершится (бесконечно долго)
            WaitForSingleObject(hThread, INFINITE);
            // закрываем хендл потока
            CloseHandle(hThread);
        }
 
        // закрытие файла
        fclose(file);
    }
 
    // подтверждение окончания
    printf("Press any key for finish and unlock\r\n");
    WaitAnyKey();
 
    // освобождение мьютекса, позволяем другому процессу получить доступ к общему ресурсу
    ReleaseMutex(hMutex);
 
    // закрытие мьютекса
    CloseHandle(hMutex);
 
    return 0;
}