Вопрос по работе WaitForSingleObject

#include <windows.h>
#include <process.h>
#include <conio.h>
#include <tchar.h>
#include <stdio.h>
 
void LastSysError(const char *Caption)
{
    char *ErrBuf = NULL;
    FormatMessage(FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM,
                              NULL, GetLastError(), 0, ErrBuf, 0, NULL);                  
    MessageBox(GetActiveWindow(), ErrBuf, Caption, MB_ICONERROR);
    LocalFree(HLOCAL(ErrBuf));
}
 
unsigned int __stdcall CalcThreadProc(void *threadNumber); // поток, следящий за нажатием клавиш - просто для остановки
unsigned int __stdcall KeyboardThreadProc(void *dummy);    // вычислитель
 
bool repeat = true; // работаем, пока true
 
#define getRnd(from, to) ((rand() % (int)(((to) + 1) - (from))) + (from)) // имитация слсучайных данных
 
#define MAX_CALC_THREAD   10                    // число вычисляющих потоков
 
#define GLOBAL_BUFFER_SZ 512       
char globalBuffer[GLOBAL_BUFFER_SZ];    // общий для всех потоков буфер  
DWORD globalBufferBI;                                   // и его текущий индекс
 
int CallCounts[MAX_CALC_THREAD];      // еще одна переменная, но по индексам разделена на потоки 
 
HANDLE hMutex;                        // синхронизация
#define MUTEX_NAME "myMutex"
#define MAX_TIME 5000                 // сколько времени ждать максимум
 
int _tmain(int argc, _TCHAR* argv[])
{
    DWORD retCode;
    
    hMutex = CreateMutex(NULL, FALSE, MUTEX_NAME);
    if (hMutex == NULL)
    {
        LastSysError("CreateMutex");
        return 0;
    }
    
    // запускаем потоки
    _beginthreadex(NULL, 0, KeyboardThreadProc, NULL, 0, NULL);
    DWORD threadCount = 0;
    for (DWORD threadCount = 1; threadCount <= MAX_CALC_THREAD; threadCount++)
    {
        CallCounts[threadCount-1] = 0;
        _beginthreadex(NULL, 0, CalcThreadProc, (void*)(_w64)threadCount, 0, NULL);
    }
    
    // работаем, пока не получим сигнал выхода
    while (repeat)
    {
        // Sleep(500); // но это увеличит риск "нехватки буфера"
        retCode = WaitForSingleObject(hMutex, MAX_TIME);
        switch (retCode)
        {
            case WAIT_OBJECT_0:
            {
                HANDLE newH = OpenMutex(MUTEX_ALL_ACCESS, FALSE, MUTEX_NAME);
                if (NULL != newH) 
                {
                    if (globalBufferBI > 0)
                    {
                        printf("%s", globalBuffer);
                        globalBufferBI = 0;
                    }
                    ReleaseMutex(newH);
                }
                ReleaseMutex(hMutex);
                break;
            }
            case WAIT_TIMEOUT:
            {
                printf("times end\n");
                repeat = false;
                break;
            }
            default:
            {
                printf("\nwait main\n");
                continue;
            }
        }
    }
    ReleaseMutex(hMutex);
    CloseHandle(hMutex);
    return 0;
}
 
unsigned int __stdcall KeyboardThreadProc(void *dummy)
{
    _getch();
    repeat = false;
    return repeat;
}
 
unsigned int __stdcall CalcThreadProc(void *threadNumber)
{
    while(repeat)
    {
        Sleep(500); // для "визуализации"
        int tmp = getRnd(0, 0x1000);
        if ((tmp & (DWORD)(_w64)threadNumber) == (DWORD)(_w64)threadNumber)
        {
            DWORD retCode   = WaitForSingleObject(hMutex, MAX_TIME);
            switch (retCode)
            {
                case WAIT_OBJECT_0:
                {
                    HANDLE newH = OpenMutex(MUTEX_ALL_ACCESS, FALSE, MUTEX_NAME);
                    if (NULL != newH) 
                    {
                        if (globalBufferBI < GLOBAL_BUFFER_SZ - 25)
                        {
                            globalBufferBI += _snprintf(globalBuffer + globalBufferBI, GLOBAL_BUFFER_SZ - globalBufferBI,
                                                                                "%02X %03X %04X\n", 
                                                                                (DWORD)(_w64)threadNumber,
                                                                                ++CallCounts [(DWORD)(_w64)threadNumber-1],
                                                                                tmp);
                        }
                        ReleaseMutex(newH);
                    }
                    else
                        printf("buffer small\n");
                
                    ReleaseMutex(hMutex);
                    break;
                }
                case WAIT_TIMEOUT:
                {
                    printf("times end\n");
                    repeat = false;
                    break;
                }
                default:
                    printf("\n%d=wait\n", (DWORD)(_w64)threadNumber);
            }
        }
    }
    _endthread();
    return 0;
}

// должно быть с опцией линкера /MT (release) или /MTd (debug)
#include <windows.h>
#include <winbase.h>
#include <process.h>
#include <conio.h>
#include <tchar.h>
#include <stdio.h>
 
void LastSysError(const char *Caption)
{
  char *ErrBuf = NULL;
  FormatMessage(FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM,
                NULL, GetLastError(), 0, ErrBuf, 0, NULL);                
  MessageBox(GetActiveWindow(), ErrBuf, Caption, MB_ICONERROR);
  LocalFree(HLOCAL(ErrBuf));
}
 
unsigned int __stdcall CalcThreadProc(void *threadNumber); // поток, следящий за нажатием клавиш - просто для остановки
unsigned int __stdcall KeyboardThreadProc(void *dummy);    // вычислитель
 
bool repeat = true; // работаем, пока true
 
#define getRnd(from, to) ((rand() % (int)(((to) + 1) - (from))) + (from)) // имитация слсучайных данных
 
#define MAX_CALC_THREAD   10          // число вычисляющих потоков
 
#define GLOBAL_BUFFER_SZ 512       
char globalBuffer[GLOBAL_BUFFER_SZ];  // общий для всех потоков буфер  
DWORD globalBufferBI;                  // и его текущий индекс
 
int CallCounts[MAX_CALC_THREAD];      // еще одна переменная, но по индексам разделена на потоки 
                                      // в ней мы будем считать число вызовов для каждого потока
                                      
HANDLE hMutex;                        // синхронизация
#define MUTEX_NAME "myMutex"
#define MAX_TIME 5000                 // сколько времени ждать максимум
 
FILE *log;
 
LONG InUse = FALSE;
 
int _tmain(int argc, _TCHAR* argv[])
{
  log = fopen("fprintf.out", "w");
  globalBufferBI = 0;
  
  hMutex = CreateMutex(NULL, FALSE, MUTEX_NAME);
  if (hMutex == NULL)
  {
    LastSysError("CreateMutex");
    return -1;
  }
  
  // запускаем потоки
  InUse = TRUE; // блокируем на время запуска потоков
  
  _beginthreadex(NULL, 0, KeyboardThreadProc, NULL, 0, NULL);
  DWORD threadCount = 0;
  for (DWORD threadCount = 1; threadCount <= MAX_CALC_THREAD; threadCount++)
  {
    CallCounts[threadCount-1] = 0;
    _beginthreadex(NULL, 0, CalcThreadProc, (void*)(_w64)threadCount, 0, NULL);
  }
  InterlockedExchange((LONG*)&InUse, FALSE); // освобождаем доступ
  
  while (repeat) // работаем, пока не получим сигнал выхода
  {
    while (InterlockedExchange(&InUse, TRUE) == TRUE) // получаем ресурс в свое распоряжение
      Sleep(0);
    
    if (globalBufferBI > 0) // если есть данные для вывода
    {
      printf("%s", globalBuffer);
      fprintf(log, globalBuffer);
      globalBufferBI = 0;
    }
    InterlockedExchange(&InUse, FALSE); // доступ к ресурсу больше не нужен
  }
  
  fclose(log);
  return 0;
}
 
// просто выход по нажатию любой клавиши
unsigned int __stdcall KeyboardThreadProc(void *dummy)
{
  _getch();
  repeat = false;
  return repeat;
}
 
unsigned int __stdcall CalcThreadProc(void *threadNumber)
{
  while(repeat)
  {
    Sleep(1); // без хотя бы какого-то минимального засыпания потоки все равно перемешиваются 
              // хотя, может быть перемешивание идет уже при выводе в файл/на экран, но от этого не легче 
    
    int tmp = getRnd(0, 0x1000); // делаем "случайные данные"
    if ((tmp & (DWORD)(_w64)threadNumber) == (DWORD)(_w64)threadNumber) // если это нужные данные
    {
      while (InterlockedExchange(&InUse, TRUE) == TRUE) // получаем ресурс в свое распоряжение
        Sleep(0);
      if (globalBufferBI < GLOBAL_BUFFER_SZ)
      {
        globalBufferBI += _snprintf(globalBuffer + globalBufferBI, GLOBAL_BUFFER_SZ - globalBufferBI,
                          "%02X %03X %04X\n", 
                          (DWORD)(_w64)threadNumber,
                          ++CallCounts [(DWORD)(_w64)threadNumber-1],
                          tmp);
      }
      InterlockedExchange(&InUse, FALSE); // доступ к ресурсу больше не нужен
    }
  }
  
  _endthreadex(0);
  return 0;
}