Почему в потоке иногда неправильно берется переменная?

Question

[Евгений Якушов]

Суть такая, есть некоторая симуляция модели, в которой создаются потоки для моделирования полета объекта

void Simulator::Start(ModuleRls &RLS)
{
    for (uint i = 0; i < flyObjVector.size(); i++)
    {
        StreamFly *obj = new StreamFly(flyObjVector, RLS, i + 1);
        obj->start();
    }
}

Сам поток:

void StreamFly::run()
{
    for (int i = 0; i < 50; i++)
    {
        qDebug() << id << "[" << QThread::currentThreadId() << "]" << RLS->getX();
    }
}

Здесь я беру координату RLS для проверки работы, она равна 50(допустим)
В логе я вижу такую картину:

1 [ 0x1a88 ] 50
1 [ 0x1a88 ] 50
1 [ 0x1a88 ] 50
1 [ 0x1a88 ] 50
1 [ 0x1a88 ] 50
1 [ 0x1a88 ] 50
1 [ 0x1a88 ] 50
1 [ 0x1a88 ] 50
1 [ 0x1a88 ] 50
1 [ 0x1a88 ] 50
1 [ 0x1a88 ] 50
1 [ 0x1a88 ] 50
6 [ 0x1cf8 ] 2675932
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
6 [ 0x1cf8 ] 49351064
2 [ 0x1c78 ] 50
6 [ 0x1cf8 ] 6900
2 [ 0x1c78 ] 6900
6 [ 0x1cf8 ] 6900
2 [ 0x1c78 ] 6900
2 [ 0x1c78 ] 6900
6 [ 0x1cf8 ] 6900
2 [ 0x1c78 ] 6900
6 [ 0x1cf8 ] 6900
7 [ 0x1d00 ] 6900
4 [ 0x1de8 ] 6900
6 [ 0x1cf8 ] 6900
4 [ 0x1de8 ] 6900
6 [ 0x1cf8 ] 6900
2 [ 0x1c78 ] 6900
4 [ 0x1de8 ] 6900
6 [ 0x1cf8 ] 6900
7 [ 0x1d00 ] 6900
4 [ 0x1de8 ] 6900
8 [ 0x1d0c ] 6900
6 [ 0x1cf8 ] 6900

Какие-то потоки получают правильно параметр, но иногда даже в одном потоке может шалить координата.
Допустим поток №1 и в нем половина правильно выводится и половина не правильно.
Не понимаю в чем проблема. С потоками на QT начал работать недавно, не судите строго :)
И еще один вопрос, почему-то после окончания симуляции, поджирает память на 1-2 мб, смотря сколько объектов запущено, допустим 1800. Да, по коду звучит бредово, я генерирую 1800 потоков... Но суть не в этом. Почему после каждого запуска, прибавляется эти 1-2мб, вектор объектов передается везде по ссылке.

Comments

[xorknown]

Советую добавить хотя бы интерфейс класса StreamFly. И код запуска старт. Вообще не понятно, когда удаляется ModuleRls, копируется ли она в StreamFly, меняет ли ее кто-то. Что происходит с памятью после старта тоже непонятно, ведь нет кода. Вывод как раз таки особо информации в себе не несет, просто видно что какой-то мусор.

[res2001]

Если отжирается память - значит есть утечки, т.е. не освобождаете что-то. Можно прогнать программу через valgrind или Intel VTune (Amplifier) - они умеют находить утечки.
Про 50 - как писали ниже - getx не потокобезопасна.
Гуглите про потокобезопасность, примитивы синхронизации, мьютексы, атомарные переменные...

[Евгений Якушов]

xorknown, res2001, getX просто return
int getX(){return state.x;};
Насчет памяти, как я выяснил, из-за вывода qDebug, закомментил его и все ок

[res2001]

Евгений Якушов, На счет getx: тут два варианта, либо какой-то поток параллельно изменяет значение. Либо у вас плавает state. Если state.x не атомарная переменная, то функция в таком виде не потокобезопасна.

[xorknown]

Евгений Якушов, кто отвечает за хранение и время жизни RLS? Хранится ли в каждом классе копия или они общая для всех. Видно что в Start передается по ссылке, но не видно, как передается в конструктор StreamFly и каким образом вдруг становится указателем. Покажите конструктор StreamFly принимающий его.

Очевидная проблема может быть в том, что RLS уже удален, во время вызова метода run, либо кто-то меняет переменную во время чтения.

Может ли измениться переменная state.x пока StreamFly запущены?

[Евгений Якушов]

xorknown, сейчас никакие переменные не меняются, чисто отработка потоков с какой-то нагрузкой

class StreamFly : public QThread
{
private:
    FlyObj * flyObjVector;
    ModuleRls * RLS;
    uint id;
protected:
    void run();
public:
    StreamFly(FlyObj&, ModuleRls&, uint);
};

StreamFly::StreamFly(FlyObj &init_ObjList, ModuleRls &init_RLS, uint init_ID)
{
    flyObjVector    = &init_ObjList;
    RLS             = &init_RLS;
    id              = init_ID;
}

RLS сам по себе просто создается и передается по ссылке, единственное в StreamFly указатель на него хранится

ModuleRls RLS = ModuleRls(x, y, r);
    model.Start(RLS);

[xorknown]

Евгений Якушов, Я вот про это и говорю. Постараюсь объяснить. Если ваш код выглядит так, то что происходит.

void someFunc(){
ModuleRls RLS = ModuleRls(x, y, r);
 model.Start(RLS);
}

Создается объект RLS и начинают стартовать потоки, пока все хорошо. Но при выходе из функции model.Start(RLS) RLS удаляется, и потоки начинают общаться с удаленной памятью, а это UB. В том месте где раньше был объект RLS может находиться любой мусор. Скорее всего у вас так и происходит.

Answer 1

[Ighor July]

без кода getX() ничего не понятно
Вероятно эта функция не потоко безопасна