[РЕШЕНО] Помогите с задачей производителя/потребителя

[Bepec]

Угу. Хорошая у тя моделька на сигнал слотах

Ну таймера нету. Хотя это уже опционально

Поток обрабатывает очередь сообщений, пока исполняется run.

Так же можно создать событийный поток вызвав QThread::run().

А exec создаст свой отдельную очередь событий, которую потом прибивать придётся ручками

to lolbla2:

Читай про QTimer и допиливай его к этому проекту.

PS а я, добрый человек, по привычке без сигнал-слотов зафигачил программку вот до чего доводит пятница.

[lolbla2]

Угу. Хорошая у тя моделька на сигнал слотах

Ну таймера нету. Хотя это уже опционально

Поток обрабатывает очередь сообщений, пока исполняется run.

Так же можно создать событийный поток вызвав QThread::run().

А exec создаст свой отдельную очередь событий, которую потом прибивать придётся ручками

to lolbla2:

Читай про QTimer и допиливай его к этому проекту.

PS а я, добрый человек, по привычке без сигнал-слотов зафигачил программку вот до чего доводит пятница.

run всегда будет исполнятся, там бесконечные циклы

[BRE]

Поток обрабатывает очередь сообщений, пока исполняется run.

Этим ты хочешь сказать, что поток будет обрабатывать сообщения без запуска exec() или ручного создания очереди?

[V1KT0P]

run всегда будет исполнятся, там бесконечные циклы

В самом QThread функция run имеет вид:

Код:

void QThread::run()
{
    (void) exec();
}

Так вот если после перегрузки ты не выполнишь exec() то не запустится механизм обработки сигнал/слотов. Учти что внутри exec() бесконечный цикл.

Короче добавил пару функций, вот то что ты хочешь с таймером: http://rghost.ru/36813776

[Bepec]

Да. Как и в случае с "невидимым виджетом", у меня это работает, а у вас невозможно теоретически. А знаешь почему? Потому что тролли сначала думают, потом делают.
Посмотри на досуге метод start()

[V1KT0P]

Да. Как и в случае с "невидимым виджетом", у меня это работает, а у вас невозможно теоретически. А знаешь почему? Потому что тролли сначала думают, потом делают.
Посмотри на досуге метод start()

Глянул но так и не понял что ты хотел сказать.

Код:

void QThread::start(Priority priority)
{
    Q_D(QThread);
    QMutexLocker locker(&d->mutex);

    if (d->isInFinish) {
        locker.unlock();
        wait();
        locker.relock();
    }

    if (d->running)
        return;

    d->running = true;
    d->finished = false;
    d->terminated = false;
    d->exited = false;
    d->returnCode = 0;

    d->handle = (Qt::HANDLE) _beginthreadex(NULL, d->stackSize, QThreadPrivate::start,
                                            this, CREATE_SUSPENDED, &(d->id));

    if (!d->handle) {
        qErrnoWarning(errno, "QThread::start: Failed to create thread");
        d->running = false;
        d->finished = true;
        return;
    }

    int prio;
    d->priority = priority;
    switch (d->priority) {
    case IdlePriority:
        prio = THREAD_PRIORITY_IDLE;
        break;

    case LowestPriority:
        prio = THREAD_PRIORITY_LOWEST;
        break;

    case LowPriority:
        prio = THREAD_PRIORITY_BELOW_NORMAL;
        break;

    case NormalPriority:
        prio = THREAD_PRIORITY_NORMAL;
        break;

    case HighPriority:
        prio = THREAD_PRIORITY_ABOVE_NORMAL;
        break;

    case HighestPriority:
        prio = THREAD_PRIORITY_HIGHEST;
        break;

    case TimeCriticalPriority:
        prio = THREAD_PRIORITY_TIME_CRITICAL;
        break;

    case InheritPriority:
    default:
        prio = GetThreadPriority(GetCurrentThread());
        break;
    }

    if (!SetThreadPriority(d->handle, prio)) {
        qErrnoWarning("QThread::start: Failed to set thread priority");
    }

    if (ResumeThread(d->handle) == (DWORD) -1) {
        qErrnoWarning("QThread::start: Failed to resume new thread");
    }
}

[V1KT0P]

А знаешь почему?

Блин только что проверил, работает. Но с какого хрена оно так работает? Как заставить сигнал встать в очередь и не выполняться пока его не позовут.
Я все время думал что сигналы ждут пока поток не завершит выполнять функцию и только тогда выполняет следующую функцию.
Я во всех своих многопоточных программах использовал только сигналы вместо мьютексов. Пипец, это наверно у меня в коде где-то скрытые баги которые ждут своего времени  .
Сигнал что прерывает выполнение текущей функции? Как сделать чтоб сигнал лежал в очереди, я же теперь не засну.

[BRE]

Сигнал что прерывает выполнение текущей функции? Как сделать чтоб сигнал лежал в очереди, я же теперь не засну.

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

[V1KT0P]

Сигнал что прерывает выполнение текущей функции? Как сделать чтоб сигнал лежал в очереди, я же теперь не засну.

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

С какого хрена сигнал делает почти прямой вызов? Я же четко указываю Qt::QueuedConnection а не Qt::DirectConnection.

Signals

Signals are emitted by an object when its internal state has changed in some way that might be interesting to the object's client or owner. Only the class that defines a signal and its subclasses can emit the signal.

When a signal is emitted, the slots connected to it are usually executed immediately, just like a normal function call. When this happens, the signals and slots mechanism is totally independent of any GUI event loop. Execution of the code following the emit statement will occur once all slots have returned. The situation is slightly different when using queued connections; in such a case, the code following the emit keyword will continue immediately, and the slots will be executed later.

If several slots are connected to one signal, the slots will be executed one after the other, in the order they have been connected, when the signal is emitted.

Signals are automatically generated by the moc and must not be implemented in the .cpp file. They can never have return types (i.e. use void).

A note about arguments: Our experience shows that signals and slots are more reusable if they do not use special types. If QScrollBar::valueChanged() were to use a special type such as the hypothetical QScrollBar::Range, it could only be connected to slots designed specifically for QScrollBar. Connecting different input widgets together would be impossible.

В самой документации утверждается что слот должен выполниться позже. Что за хрень?

[Igors]

В аттаче подправленный вариант (используется UI что сделал V1KT0P). Если нажимать кнопку с интервалом 2 сек и более - consumer получит все что сделал producer. Если быстрее - строки будут теряться (что и требуется в задании)

[lolbla2]

В аттаче подправленный вариант (используется UI что сделал V1KT0P). Если нажимать кнопку с интервалом 2 сек и более - consumer получит все что сделал producer. Если быстрее - строки будут теряться (что и требуется в задании)

Спасибо конечно, но что у тебя что у Viktor'a одинаково у вас, сообщения отправляет производитель и потребитель мгновенно принимает, ничего никогда не теряется.

P.S. задание чуток изменилось:

теперь надо чтобы сообщение не терялись.

поток 1-> по нажатию кнопки создаёт сообщения. кладёт в очередь. И если поток 2 готов принять сообщение, то берёт из очереди и отправляет.

поток 2-> ждёт каждые 2 секунды просматривает буфер. Если там чото есть считывает ( то есть этот поток моделирует некое устройство, которое способно только каждые 2 сек считывать). Пока поток 2 ждёт, поток 1 не должен в буфер ничего класть.

[lolbla2]

Кстати мьютекс блокирует часть кода расположенную в пределах между
lock()
// код который заблокирован для доступа
 unlock() ?

а как заблокировать доступ к переменной?

[Bepec]

ЛолБла2 - у тебя есть уже готовая программа, допиливай её сам и разбирайся. (И другим советую не писать ему программу, а то разлениться )

Заблокировать доступ к переменной - закрыть мьютексами все функции, которые её запрашивают.

V1KT0P
Насчёт start я наверно погорячился Выкобениться решил. Каюсь.

Где то упоминалось, что при вызове метода start, а затем start вызываеь run, а затем run вызывает QThread::exec() в качестве скрытого приватного поля класса

Виктор, LolBla2 - советую почитать http://habrahabr.ru/blogs/qt_software/115830/ (это не реклама, а статья по Qt, ежели Пантер обратит свой гнев на меня )

[BRE]

Где то упоминалось, что при вызове метода start, а затем start вызываеь run...

Точнее start создает новый поток в котором и выполняет метод run. А реализация run из QThread, как раз запускает exec, для обработки очереди событий.
Если ты сам переопределяешь run и не запускаешь очередь событий, то события обрабатываться не будут. Чудес не бывает.

а затем run вызывает QThread::exec() в качестве скрытого приватного поля класса

Расскажи подробней про эту новую возможность С++.

[Bepec]

BRE сделай проект. Переопредели RUN в бесконечный цикл и сделай 1 слот, без exec().

Сконеекть, отэмить сконнекченный сигнал из основного потока в созданный. Слот выполнится или нет?

Насколько я помню, BRE, ты уже агрился на меня в теме "Невидимый плагин для дизайнера", а под конец, поняв о чём речь, постыдно убежал...

Напомню:

to BRE: Без вмешательства пользователя плагин будет прилинкован к проекту, если его перетащить в дизайнере. Никаких "ручных" правок *.pro , линковок проекта, добавления в свойства проекта необходимых путей. Пользователь перетащит и будет пользоваться, заместо "ковыряния, линковок".
Я был против "ручками дописываем в *.pro, прописываем путь в **, собираем".

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

А под конец неожиданно мир изменился и это стало возможно.
Совет: Проверяй сначала сам. Не обо всём в учебниках пишут.