VPF::Критические секции - Форум программистов

Nudnik

Дата 29.3.2008, 13:38 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 33
Регистрация: 15.9.2007

Репутация: нет
Всего: нет

У меня есть главный процесс и вспомогательный поток. Я создаю дочерний поток и он выполянет функцию sumFunc.

Код


#include "stdafx.h"
#include <windows.h>

#define MAIN_ID 0
#define THREAD_ID 1

#define enter EnterCriticalSection
#define leave LeaveCriticalSection

CRITICAL_SECTION cSections[2];

DWORD WINAPI sumFunc(LPVOID param)
{    
    enter(&cSections[THREAD_ID]);

    while(TRUE)
    {
        enter(&cSections[MAIN_ID]);

        printf("SUM\n");
                                              
        leave(&cSections[MAIN_ID]);
        leave(&cSections[THREAD_ID]);
    }

    return 0;
}    

VOID WINAPI delegateCall()             
{
    leave(&cSections[MAIN_ID]);         
    enter(&cSections[THREAD_ID]);
    enter(&cSections[MAIN_ID]);
}

VOID WINAPI mainLogic()
{       
    delegateCall();
    delegateCall();                   
    delegateCall();
}

int _tmain(int argc, _TCHAR* argv[])
{
    // Thread
    DWORD threadId;
    HANDLE thread = CreateThread(NULL, 0, sumFunc, NULL, 0, &threadId);
    
    // Critical sections
    InitializeCriticalSection(&cSections[MAIN_ID]);
    InitializeCriticalSection(&cSections[THREAD_ID]);              
    
    enter(&cSections[MAIN_ID]);

    //
    mainLogic();

    //
    CloseHandle(thread);

    return 0;
}

У меня имеется 2 критические секции (именно с помощью критических функций мне необходимо произвести синхронизацию). Функция delegateThread занимается взаимодействием с потоком. Необходимо, чтобы поток с sumFunc работал постоянно, а когда нужно было выполнить содержимое функции sumFunc, то я бы вызывал delegateThread(). В главной функции (mainLogic) я 3 раза вызываю delegateThread и соответственно хочу, чтобы 3 раза исполнилось содерджимое функции sumFunc то есть:

Код


printf("SUM\n");

То есть должен вывести:
SUM
SUM
SUM

Подскажите, как правильно в delegateThread и sumFunc расставить вход / выход в критические секции?

korian

Дата 29.3.2008, 14:01 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 651
Регистрация: 8.3.2008
Где: Украина, Харьков

Репутация: 4
Всего: 17

что-то вы нереальное хотите помоему.
критические секции для обеспечения доступа к данным, а то что вы хотите я вообще не понимаю.

Цитата(Nudnik @ 29.3.2008, 12:38

)

я 3 раза вызываю delegateThread и соответственно хочу, чтобы 3 раза исполнилось содерджимое функции sumFunc то есть

такое можно сделать примерно так:

Код


#define enter EnterCriticalSection
#define leave LeaveCriticalSection

CRITICAL_SECTION cSection;
int GlobalCount = 0;

DWORD WINAPI sumFunc(LPVOID param)
{    

    while(TRUE)
    {
        enter(&cSection);
        for (; GlobalCount != 0; GlobalCount--)
        {
                printf("SUM\n");
        }
        leave(&cSection);
        Sleep(50);
    }

    return 0;
}    

VOID WINAPI delegateCall()             
{
        enter(&cSection);
        GlobalCount++;
        leave(&cSection);
}

VOID WINAPI mainLogic()
{       
    delegateCall();
    delegateCall();                   
    delegateCall();
}

int _tmain(int argc, _TCHAR* argv[])
{
    // Thread
    DWORD threadId;
    HANDLE thread = CreateThread(NULL, 0, sumFunc, NULL, 0, &threadId);
    
    // Critical sections
    InitializeCriticalSection(&cSection);

    mainLogic();

    //
    CloseHandle(thread);

    return 0;
}

Добавлено через 6 минут и 58 секунд
а если вы хотите чтобы ваш код работал, надо Sleep расставлять, и все равно это не будет гарантировать правильную работу во всех случаях.

Nudnik

Дата 29.3.2008, 14:23 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 33
Регистрация: 15.9.2007

Репутация: нет
Всего: нет

Да, Sleep не даёт никаких гарантий. Просто у меня задача такова, что есть главный поток есть дочерний поток, который постоянно работает. Я из главного обращаюсь к дочернему, последний выполняет операции и в конце передает управление обратно главному. И так к дочернему потоку я могу обращаться много раз. Синхронизацию сделать обязхательно через критические секции.

baldina

Дата 29.3.2008, 14:34 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 3433
Регистрация: 5.12.2007
Где: Москва

Репутация: нет
Всего: 101

Nudnik,
Тебе надо, что бы поток висел в памяти, желательно не занимая процессорного времени, а при наступлении события (команды) выполнял некие действия.
Для этого используется Event. Читай про WaitFor...() функции.
А критические секции и т.п. блокировки используются для обеспечения целостности доступа к данным.

korian

Дата 29.3.2008, 14:36 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 651
Регистрация: 8.3.2008
Где: Украина, Харьков

Репутация: 4
Всего: 17

сделать можно так:
но как сказал baldina, для этого лучше использовать WaitFor... функции.

Код


#define enter EnterCriticalSection
#define leave LeaveCriticalSection

CRITICAL_SECTION cSection;
bool GlobalFlag = false;

DWORD WINAPI sumFunc(LPVOID param)
{    

    while(TRUE)
    {
        enter(&cSection);
        if (GlobalFlag)
        {
                printf("SUM\n");
                GlobalFlag = false;
        }
        leave(&cSection);
        Sleep(50);
    }

    return 0;
}    

VOID WINAPI delegateCall()             
{
        enter(&cSection);
        GlobalFlag = true;
        leave(&cSection);
        bool tmpflag = true;
        while(tmpflag)
        {
                enter(&cSection);
                tmpflag = GlobalFlag;
                leave(&cSection);
        }
}

VOID WINAPI mainLogic()
{       
    delegateCall();
    delegateCall();                   
    delegateCall();
}

int _tmain(int argc, _TCHAR* argv[])
{
    // Thread
    DWORD threadId;
    HANDLE thread = CreateThread(NULL, 0, sumFunc, NULL, 0, &threadId);
    
    // Critical sections
    InitializeCriticalSection(&cSection);

    mainLogic();

    //
    CloseHandle(thread);

    return 0;
}

Это сообщение отредактировал(а) korian - 29.3.2008, 14:38

baldina

Дата 29.3.2008, 14:40 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 3433
Регистрация: 5.12.2007
Где: Москва

Репутация: нет
Всего: 101

Цитата

Синхронизацию сделать обязхательно через критические секции

Это странно. Хотя и возможно - korian тебе показал как.

Код


bool do_sum;

DWORD WINAPI sumFunc(LPVOID param)
{    

    while(TRUE)
    {
        enter(&cSection);
        if (do_sum)
        {
           printf("SUM\n");
           do_sum = false;
        }
        leave(&cSection);
    }

    return 0;
}    

VOID WINAPI delegateCall()             
{
        enter(&cSection);
        do_sum = true;
        leave(&cSection);
}

Добавлено через 43 секунды
korian, пока я писал, ты уж тут smile

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| C/C++: Системное программирование и WinAPI \| Следующая тема »