Pasted

#include <windows.h>
#include <iostream>
 
#define THREADCOUNT 2
 
HANDLE mutex;
 
DWORD WINAPI WriteToDatabase(LPVOID);
 
int main(void) {
    setlocale(LC_ALL, "RUSSIAN");
 
    HANDLE threads[THREADCOUNT];
    DWORD threadID;
    int i;
 
    // Создаем мьютекс без начального владельца
    mutex = CreateMutex(
        NULL,              // Структура, которая определяет безопасность (NULL - по умолчанию)
        FALSE,             // Нет начального вледльца
        NULL);             // Имя мьютекста
 
    if (mutex == NULL) {
        std::cerr << "Не удалось создать мьютекс: " << (int) GetLastError() << std::endl;;
        return 1;
    }
 
    // Создаем потоки
    for (i = 0; i < THREADCOUNT; i++) {
        threads[i] = CreateThread(
            NULL,       // Структура, которая определяет безопасность (NULL - по умолчанию)
            0,          // Размер стека (0 - стандартное значение)
            (LPTHREAD_START_ROUTINE)WriteToDatabase, // Указатель на фунцию, которая выполнится в потоке
            NULL,       // Аргументы функции
            0,          // Флаги, которые управляют созданием потока.
            &threadID); // Указатель на переменную, в которую передастся номер потока
 
        // Если поток не создался
        if (threads[i] == NULL) {
            std::cerr << "Не удалось создать поток: " << (int) GetLastError() << std::endl;
            return 1;
        }
        std::cout << "Создан поток " << (int)threadID << std::endl;
    }
 
    // Ждем пока все потоки завершат свою работу
    WaitForMultipleObjects(THREADCOUNT, threads, TRUE, INFINITE);
 
    // Уничтожаем потоки
    for (i = 0; i < THREADCOUNT; i++) {
        CloseHandle(threads[i]);
    }
 
    // Уничтожаем мьютекс
    CloseHandle(mutex);
 
    system("pause");
    return 0;
}
 
DWORD WINAPI WriteToDatabase(LPVOID lpParam) {
    // lpParam not used in this example
    UNREFERENCED_PARAMETER(lpParam);
 
    DWORD waitResult;
 
    // Блокируем мьютекс
    waitResult = WaitForSingleObject(
        mutex,    // Мьютекс
        INFINITE);  // Бесконечное время блокировки
 
    switch (waitResult) {
        // Мьютекс 
        case WAIT_OBJECT_0:
            __try {
                // Выполняем функцию
                std::cout << "Выполняется функция в потоке " << GetCurrentThreadId() << std::endl;
            }
 
            __finally {
                // Освобождаем сокет
                if (!ReleaseMutex(mutex)) {
                    std::cerr << "Ошибка при освобождении мьютекса" << std::endl;
                }
            }
            break;
 
            // The thread got ownership of an abandoned mutex
            // The database is in an indeterminate state
        case WAIT_ABANDONED:
            return FALSE;
 
    }
    return TRUE;
}