Освобождение памяти в многопоточной функции

@tanya1179 · Регистрация: 03.09.2015

Author24 — интернет-сервис помощи студентам

C++

void DispThreadsNT::SetCallDZ (MESDZ* pMesDZ,     
                               LPVOID pData,     
                               int nLenData,     
                               DWORD dwPause)     
{
    MESCALL MesCall;
    
    CopyMemory (&(MesCall.MesDZ), pMesDZ, sizeof (MESDZ));
    MesCall.nLenData = 0;
    MesCall.pData = NULL;
 
    MesCall.dwPause = dwPause;
    
    
    if (nLenData != 0 && pData != NULL)
    {
       
        MesCall.pData = new BYTE [nLenData];
        
        if (MesCall.pData != NULL)
        {
            
            CopyMemory (MesCall.pData, pData, nLenData);
            MesCall.nLenData = nLenData;
        }
        else
            MesCall.pData = NULL;
    }
    
    
    MESCALL* pMesCallData = new MESCALL;
    if (pMesCallData)
 
 
        CopyMemory (pMesCallData, &MesCall, sizeof(MESCALL));
 
    
   if (pMesDZ->wParam == 0xFFFF)
       QApplication::sendEvent(this, new UserEvent(MES_CALL_DZ,0,(LPARAM)pMesCallData));
   else
       postEvent(this, new UserEvent(MES_CALL_DZ,0,(LPARAM)pMesCallData));
 
}
 
Помогите, пожалуйста, начинающему программисту. При работе функции не освобождается память, приложение ест оперативку. 
 
Объект MesCall.pData создается, но не удаляется. Не соображу как правильно его удалить, чтобы многотопочность не пострадала.

@DrOffset · 19.10.2019, 21:11

tanya1179, освобождать память в вашем случае должен тот, кто UserEvent получает.
Если эти данные только читаются получателем (в смысле не он не принимает владение ими), то можно освобождение сделать в деструкторе UserEvent.

@tanya1179 · 19.10.2019, 21:29 **[ТС]**

UserEvent определен вот так:

C++

class UserEvent : public QCustomEvent
{
public:
    UserEvent(UINT Msg, WPARAM wP, LPARAM lP);
    WPARAM GetWParam() {return wParam;}
    LPARAM GetLParam() {return lParam;}
private:
    WPARAM wParam;
     LPARAM lParam;
};

Подскажите как написать деструктор для удаления вышеописанного объекта

@DrOffset · 19.10.2019, 22:21

tanya1179, Лучше сделать как-то так:

C++

class UserMesCallEvent : public UserEvent 
{
public:
    UserMesCallEvent(UINT Msg, WPARAM wP, std::unique_ptr<MESCALL> && lP) 
        : UserEvent(Msg, wP, (LPARAM)lP.get()), lParam(std::move(lP))
    { }
 
private:
    std::unique_ptr<MESCALL> lParam;
};
 
...............
 
 
void DispThreadsNT::SetCallDZ (MESDZ* pMesDZ,     
                               LPVOID pData,     
                               int nLenData,     
                               DWORD dwPause)     
{
    std::unique_ptr<MESCALL> pMesCall(new(std::nothrow) MESCALL);
    if(pMesCall)
    {
        CopyMemory(&pMesCall->MesDZ, pMesDZ, sizeof(MESDZ));
        pMesCall->nLenData = 0;
        pMesCall->pData = NULL;
 
        pMesCall->dwPause = dwPause;
       
        if(nLenData != 0 && pData != NULL)
        {
            pMesCall->pData = new(std::nothrow) BYTE[nLenData];
            if(pMesCall->pData)
            {
                CopyMemory(pMesCall->pData, pData, nLenData);
                pMesCall->nLenData = nLenData;
            }
        }
    }
    if(pMesDZ->wParam == 0xFFFF)
        QApplication::sendEvent(this, new UserMesCallEvent(MES_CALL_DZ, 0, std::move(pMesCall));
    else
        postEvent(this, new UserMesCallEvent(MES_CALL_DZ, 0, std::move(pMesCall)));
}

Добавлено через 4 минуты
У MESCALL тоже нужен деструктор, чтобы почистить pData.
Если MESCALL - это сторонняя сишная структура, которую нельзя менять, то вопрос можно решить написав правильный deleter для unique_ptr (который перед удалением самого объекта MESCALL, сначала проверит и освободит буфер pData).

@tanya1179 · 19.10.2019, 22:32 **[ТС]**

Сообщение от DrOffset

Если MESCALL - это сторонняя сишная структура, которую нельзя менять, то вопрос можно решить написав правильный deleter для unique_ptr

Структура MESCALL вот такая:

C++

struct MESCALL
{
    MESDZ       MesDZ;              
    LPVOID      pData;           
    int      nLenData;            
    DWORD     dwPause;           
};

Понимаю, что выгляжу совсем неопытной(это так и есть), но помогите с последним шагом, пожалуйста.

@DrOffset · 19.10.2019, 22:36

Сообщение от tanya1179

помогите с последним шагом, пожалуйста.

C++

struct MESCALLDeleter
{
    void operator()(MESCALL * ptr)
    {
        delete[] (BYTE*)ptr->pData;
        delete ptr;
    }
};
 
typedef std::unique_ptr<MESCALL, MESCALLDeleter> PMESCALL;
 
class UserMesCallEvent : public UserEvent 
{
public:
    UserMesCallEvent(UINT Msg, WPARAM wP, PMESCALL && lP) 
        : UserEvent(Msg, wP, lP.get()), lParam(std::move(lP))
    { }
    
private:
    PMESCALL lParam;
};
 
...............
 
void DispThreadsNT::SetCallDZ (MESDZ* pMesDZ,     
                               LPVOID pData,     
                               int nLenData,     
                               DWORD dwPause)     
{
    PMESCALL pMesCall( new(std::nothrow) MESCALL );
    if(pMesCall)
    {
        CopyMemory (&pMesCall->MesDZ, pMesDZ, sizeof(MESDZ));
        pMesCall->nLenData = 0;
        pMesCall->pData = NULL;
 
        pMesCall->dwPause = dwPause;
       
        if(nLenData != 0 && pData != NULL)
        {
            pMesCall->pData = new(std::nothrow) BYTE[nLenData];
            if(pMesCall->pData)
            {
                CopyMemory(pMesCall->pData, pData, nLenData);
                pMesCall->nLenData = nLenData;
            }
        }
    }
    if(pMesDZ->wParam == 0xFFFF)
        QApplication::sendEvent(this, new UserMesCallEvent(MES_CALL_DZ, 0, std::move(pMesCall));
    else
        postEvent(this, new UserMesCallEvent(MES_CALL_DZ, 0, std::move(pMesCall)));
}

@tanya1179 · 19.10.2019, 22:41 **[ТС]**

Спасибо огромное! Это просто исчерпывающе!

@DrOffset · 19.10.2019, 22:43

tanya1179, для unique_ptr на забудьте #include <memory>.

Некоторое замечание по этому коду: у вас может все сломаться, если вы попытаетесь передавать LPARAM от полученного Event`а (в месте обработки) куда-то, где он будет использоваться дольше, чем живет объект события. Учитывайте это. Мне отсюда может быть не видно всех деталей.

@tanya1179 · 20.10.2019, 00:13 **[ТС]**

Спасибо, учту обязательно. Код достался мне в наследство, еще в нем разбираюсь)
..

@tanya1179 · 21.10.2019, 13:44 **[ТС]**

Попробовала это решение, но есть одно но! Я не могу использовать с++11, поэтому unique_ptr мне не доступен, к сожалению.
Помогите найти решение без него.

Алексей1153 · 21.10.2019, 13:48

tanya1179, IDE какая ?

@tanya1179 · 21.10.2019, 14:03 **[ТС]**

gcc 3.4.3, qt-3.3

Алексей1153 · 21.10.2019, 14:07

tanya1179, а чего Qt такая древняя? В Qt есть класс QSharedPointer , но я не знаю, когда его ввели

udp - Этот класс был введён в Qt 4.5.

@Ygg · 21.10.2019, 14:08

C++

   if (pMesDZ->wParam == 0xFFFF)
       QApplication::sendEvent(this, new UserEvent(MES_CALL_DZ,0,(LPARAM)pMesCallData));
   else
       postEvent(this, new UserEvent(MES_CALL_DZ,0,(LPARAM)pMesCallData));

У вас тут сложная конструкция отправки сообщения. Сообщение может быть отправлено синхронно или асинхронно в зависимости от значения wParam. Если верить документации Qt, то для синхронного вызова (send) уничтожение объекта возлагается на вызывающую сторону, а для асинхронного (post) уничтожением объекта займётся сам Qt.

@tanya1179 · 21.10.2019, 14:11 **[ТС]**

В qt-3.3 нет QSharedPointer еще, он только в 4-ой появился

Алексей1153 · 21.10.2019, 14:13

tanya1179, а вот ещё вопрос. Я так понял, ты в пределах одного приложения отправляешь сообщение, содержащее экземпляр типа MESCALL. Может, стОит заменить на глобальную очередь (синхронизированную, если многопоточка).

@tanya1179 · 21.10.2019, 14:17 **[ТС]**

Приложение писала не я, оптимизировать пытаюсь, можно попробовать в синхронизированную очередь все сложить, посмотреть , не будет ли тормозить...

Алексей1153 · 21.10.2019, 14:19

tanya1179, тормозить там нечему. Принимающая сторона в таймере (интервал зависит от задач) или в своём потоке вытаскивает сообщения и обрабатывает

@tanya1179 · 21.10.2019, 14:23 **[ТС]**

Спасибо, попробую

@DrOffset · 21.10.2019, 18:38

Сообщение от tanya1179

Попробовала это решение, но есть одно но! Я не могу использовать с++11, поэтому unique_ptr мне не доступен, к сожалению.
Помогите найти решение без него.

Такие важные вещи стоит сразу указывать.
Вот код для С++03.

Кликните здесь для просмотра всего текста

C++

class UserMesCallEvent : public UserEvent 
{
public:
    UserMesCallEvent(UINT Msg, WPARAM wP, std::auto_ptr<MESCALL> lP) 
        : UserEvent(Msg, wP, lP.get()), lParam(lP)
    { }
    ~UserMesCallEvent()
    {
        if(lParam.get())
        {
            delete[] (BYTE *)lParam->pData;
        }
    }
    
private:
    std::auto_ptr<MESCALL> lParam;
};
 
...............
 
void DispThreadsNT::SetCallDZ (MESDZ* pMesDZ,     
                               LPVOID pData,     
                               int nLenData,     
                               DWORD dwPause)     
{
    std::auto_ptr<MESCALL> pMesCall( new(std::nothrow) MESCALL );
    if(pMesCall.get())
    {
        CopyMemory (&pMesCall->MesDZ, pMesDZ, sizeof(MESDZ));
        pMesCall->nLenData = 0;
        pMesCall->pData = NULL;
 
        pMesCall->dwPause = dwPause;
       
        if(nLenData != 0 && pData != NULL)
        {
            pMesCall->pData = new(std::nothrow) BYTE[nLenData];
            if(pMesCall->pData)
            {
                CopyMemory(pMesCall->pData, pData, nLenData);
                pMesCall->nLenData = nLenData;
            }
        }
    }
    if(pMesDZ->wParam == 0xFFFF)
        QApplication::sendEvent(this, new UserMesCallEvent(MES_CALL_DZ, 0, pMesCall);
    else
        postEvent(this, new UserMesCallEvent(MES_CALL_DZ, 0, pMesCall));
}

@tanya1179 0 / 0 / 0 Регистрация: 03.09.2015 Сообщений: 11
	21.10.2019, 14:03 [ТС]	12
	gcc 3.4.3, qt-3.3 0

Алексей1153 фрилансер 5498 / 5094 / 1047 Регистрация: 11.10.2019 Сообщений: 13,341
	21.10.2019, 14:13	16
	tanya1179, а вот ещё вопрос. Я так понял, ты в пределах одного приложения отправляешь сообщение, содержащее экземпляр типа MESCALL. Может, стОит заменить на глобальную очередь (синхронизированную, если многопоточка). 0

Освобождение памяти в многопоточной функции

Решение

Решение

@DrOffset 18841 / 9840 / 2408 Регистрация: 30.01.2014 Сообщений: 17,281
	19.10.2019, 21:11	2
	tanya1179, освобождать память в вашем случае должен тот, кто `UserEvent` получает. Если эти данные только читаются получателем (в смысле не он не принимает владение ими), то можно освобождение сделать в деструкторе UserEvent. 1

@tanya1179 0 / 0 / 0 Регистрация: 03.09.2015 Сообщений: 11
	19.10.2019, 22:41 [ТС]	7
	Спасибо огромное! Это просто исчерпывающе! 0

@DrOffset 18841 / 9840 / 2408 Регистрация: 30.01.2014 Сообщений: 17,281
	19.10.2019, 22:43	8
	tanya1179, для unique_ptr на забудьте #include <memory>. Некоторое замечание по этому коду: у вас может все сломаться, если вы попытаетесь передавать LPARAM от полученного Event`а (в месте обработки) куда-то, где он будет использоваться дольше, чем живет объект события. Учитывайте это. Мне отсюда может быть не видно всех деталей. 1

@tanya1179 0 / 0 / 0 Регистрация: 03.09.2015 Сообщений: 11
	20.10.2019, 00:13 [ТС]	9
	Спасибо, учту обязательно. Код достался мне в наследство, еще в нем разбираюсь) .. 0

@tanya1179 0 / 0 / 0 Регистрация: 03.09.2015 Сообщений: 11
	21.10.2019, 13:44 [ТС]	10
	Попробовала это решение, но есть одно но! Я не могу использовать с++11, поэтому unique_ptr мне не доступен, к сожалению. Помогите найти решение без него. 0

Алексей1153 фрилансер 5498 / 5094 / 1047 Регистрация: 11.10.2019 Сообщений: 13,341
	21.10.2019, 13:48	11
	tanya1179, IDE какая ? 0

Алексей1153 фрилансер 5498 / 5094 / 1047 Регистрация: 11.10.2019 Сообщений: 13,341
	21.10.2019, 14:07	13
	tanya1179, а чего Qt такая древняя? В Qt есть класс QSharedPointer , но я не знаю, когда его ввели udp - Этот класс был введён в Qt 4.5. 0

@tanya1179 0 / 0 / 0 Регистрация: 03.09.2015 Сообщений: 11
	21.10.2019, 14:11 [ТС]	15
	В qt-3.3 нет QSharedPointer еще, он только в 4-ой появился 0

@tanya1179 0 / 0 / 0 Регистрация: 03.09.2015 Сообщений: 11
	21.10.2019, 14:17 [ТС]	17
	Приложение писала не я, оптимизировать пытаюсь, можно попробовать в синхронизированную очередь все сложить, посмотреть , не будет ли тормозить... 0

Алексей1153 фрилансер 5498 / 5094 / 1047 Регистрация: 11.10.2019 Сообщений: 13,341
	21.10.2019, 14:19	18
	tanya1179, тормозить там нечему. Принимающая сторона в таймере (интервал зависит от задач) или в своём потоке вытаскивает сообщения и обрабатывает 0

@tanya1179 0 / 0 / 0 Регистрация: 03.09.2015 Сообщений: 11
	21.10.2019, 14:23 [ТС]	19
	Спасибо, попробую 0