очередь с приоритетом

#include <windows.h>
DWORD countThread,simbols; // переменная для сохранения к-ва потоков
HANDLE hInput,hOutput,semafor,semafor1; // хендлы буфера вводы-вывода консои,хендлы семафоров
char NameSemaphore1[]="port1"; // имя первого семафора
char NameSemaphore2[]="port2"; // имя второго семафора

SYSTEMTIME sysTime;

struct iTread{      //основная структура
    DWORD id; //идентификатор потока
    DWORD time; //время отправки сообщения
    DWORD ticet; // время ожидания в милисикундах
    DWORD prioriti; //приоритет потока
} masiv[11];

struct iPriority{   //дополнительная структура.При помощи даной структуры каждый поток узнаёт свой приоритет   
    DWORD prioritet; //Также если доработать программу даная структура может использоватся для
    DWORD id;       // динамического изменения приоритета потока.Поток ищет свой идентификатор
} masiv1[10];           // и присваивает себе приоритет.

bool FLAG=true;
DWORD WINAPI client(LPVOID);    // обявление клиентской процедуры
DWORD  WINAPI server(LPVOID);   //Обявлени серверной процедуры


int main(int argc,char* argv[]) // главная процедура
{
    char mes1[]="Введите количество потоков(не больше 9) \n";   //текстовые сообщения
    char mes3[]="Тестовая Программа";
    char mes4[]="Превышен лимит потоков,завершение программы!!!!";
    char mes5[]="Для выхода нажмите ESC \n";
    char mes2[10];  //буфер для ввода к-ва потоков
    INPUT_RECORD ir; //структура для обработки сообщений приходящих на консоль
   
    FreeConsole();  // освобождаем консоль по умолчанию
    AllocConsole(); //выделяем свою консоль
    hInput=GetStdHandle(STD_INPUT_HANDLE);  //получаем хендл буфера ввода консоли
    hOutput=GetStdHandle(STD_OUTPUT_HANDLE); //получаем хендл буфера вывода
    CharToOem(mes1,mes1); //перекодируем выводимые текстовые сообщения
    CharToOem(mes3,mes3);
    CharToOem(mes4,mes4);
    CharToOem(mes5,mes5);
    SetConsoleTitle(mes3); //устанавливаем заголовок консоли
    WriteConsole(hOutput,mes5,lstrlen(mes5),&simbols,0); // пишем в консоль
    WriteConsole(hOutput,mes1,lstrlen(mes1),&simbols,0);
    ReadConsole(hInput,mes2,9,&simbols,0); //читаем из консоли к-во создаваемых потоков
    countThread=atol(mes2); //перекодируем строку в число и сохраняем к-во потоков в переменной
    if (countThread>=10)    // проверяем не привышен ли лимит запрошеных потоков
    {
        WriteConsole(hOutput,mes4,lstrlen(mes4),&simbols,0); //если привышен-на выход
        Sleep(5000);
        return(0);
    }
    semafor=CreateSemaphore(0,1,1,NameSemaphore1); //создаём первый семафор
    semafor1=CreateSemaphore(0,1,1,NameSemaphore2); //создаём второй семафор
    //даные семафоры будут работать по принцыпу обратной связм что позволит жостко синхронизировать работу\
    //сервера и клиентов

   
    int pvParam=0,i=1;
    CreateThread(NULL,0,server,(LPVOID) &pvParam,0,NULL); //создаём серверную процедуру

    while (countThread) {       //при помощи цикла создаём заказаное количество клиентов
    --countThread;              // и устанавливаем их приоритет
    CreateThread(NULL,0,client,(LPVOID) &pvParam,0,&masiv1.id);
    masiv1.prioritet=i; //формируем масив структур по соотношению: идентификатор/приоритет
    ++i;
    }
   
   
   
   
    while (1)       //процедура обработки сообщений консоли
    {
        ReadConsoleInput(hInput,&ir,1,&simbols); //функция чтения сообщений
        if(ir.EventType==KEY_EVENT)             // идентификация типа сообщения
        {
            if(ir.Event.KeyEvent.bKeyDown)      // идентификация нажатия клавишы
                switch(ir.Event.KeyEvent.uChar.AsciiChar) //проверка кода клавишы
            {
                case (0x1b):
                    FLAG=false;  //выход по нажатию ESC
                    CloseHandle(semafor);
                    CloseHandle(semafor1);
                    Sleep(1000);
                    return(0);
                   
            }
        }
    }
}



   

DWORD WINAPI client(LPVOID pvParam) //клиентская процедура
{
   
    DWORD amon=50;
   

    while(amon>0)
    {
   
        masiv[0].ticet=GetTickCount();
        GetLocalTime(&sysTime); //получаем локальное время
        masiv[0].time=sysTime.wMilliseconds; //записываем милисикунды         
        masiv[0].id=GetCurrentThreadId(); //получаем идентификатор потока
       
        for(int i=10;i>0;i--) // цикл ищет приоритет потока по его идентификатору
        {
            if(masiv[0].id==masiv1.id)
                masiv[0].prioriti=masiv1.prioritet;
        }

   
       
               
            --amon;
        ReleaseSemaphore(semafor1,1,NULL); // разрешаем работу серверу       
        WaitForSingleObject(semafor,INFINITE);  // ждём разрешения на продолжение работы
    }
    ReleaseSemaphore(semafor1,1,NULL);
    FLAG=false;
    return(0);
}



DWORD  WINAPI server(LPVOID pvParam)  // серверная процедура

{
   
    DWORD size,simbols,i,j,sizeM=10; //временные переменные
   
    char buf1[100];     // буфер форматирования
    char mes[]="Идентификатор: %u            Время: %u      Приоритет: %u  Тики: %u \x0d\x0a ";
    HANDLE fHandle=CreateFile("LOG.txt",GENERIC_WRITE,0,0,OPEN_ALWAYS,0,0); //открываем лог файл \
    //если файла небыло то он создаётся.
     
    if( fHandle==INVALID_HANDLE_VALUE) // проверка создания файла
    {
        MessageBox(0,"Немогу создать файл,перезапустите программу","Ошибка",0);
        return(0);
    }
    while (FLAG)
    {
       
        WaitForSingleObject(semafor1,INFINITE); //ждём разрешения на работу от клиента
        for(i=10;i>0;i--)
       
        {
            if(masiv.prioriti==0) // в даном цикле мы заполняем очередь просматривая пустые \
                                    //  ячейки масива
            {
                masiv=masiv[0]; //находим пустую ячейку масива и заполняем её
                goto a;             // идём за новой порцией данных
            }
                                // очередь сформирована-идём на сортировку
        }
        for(i=0;i<sizeM;i++)  // организуем простейшую пузырьковую сортировку (масив небольшой)
        {
            for(j=sizeM-1;j>i;j--)
            {
                if(masiv[j-1].prioriti > masiv[j].prioriti)
                {
                    masiv[11]=masiv[j-1];masiv[j-1]=masiv[j];masiv[j]=masiv[11];
                }
            }
        }
   



       
        wsprintf(buf1,&mes[0],masiv[0].id,masiv[0].time,masiv[0].prioriti); // форматируем первый элемент масива 
        size=GetFileSize(fHandle,0); //получаем размер файла
        SetFilePointer(fHandle,size,0,FILE_BEGIN);  //устанавливаем файловый указатель в конец файла
        WriteFile(fHandle,buf1,lstrlen(buf1),&simbols,0); //пишем в файл
a:
        ReleaseSemaphore(semafor,1,NULL); //разрешаем работу клиенту
    }
    CloseHandle(fHandle); //закрываем хендл файла
   
   
    return(0); //выходим
}