Приостановить поток

[qt_user]

"многопоточное программирование" только на первый взгляд кажется простым, но это не так 

так с этим никто и не спорит

[qt_user]

2) Эти операции атомарные, но чтение+запись такой переменной нужно защищать блокировками

хотелось бы еще такое узнать, а если доступ к переменной через ссылку или через указатель:

Код:

1. wState = &workState;
2. *wState = run;
3. if (*wState == stop) {}

2 и 3 также будет атомарно?

[Igors]

2 и 3 также будет атомарно?

Будет-то будет, но код в котором даже все операции атомарны может успешно рухнуть - потому что др нитка может вклиниться между операциями. Простой пример

Код

C++ (Qt)
int a. b;
..
if (a == b) 
 a = 0;
 b = 100;
}  
 

Здесь все атомарно, но тем не менее придется это место защищать блокировкой. Начиная от момента когда выполнилось a == b до момента когда выполнится a = 0 могло произойти многое, др нитка(и) могли изменить  a и b как они хотели.

С Ларисой я действительно пил вино, но это было на пасху

[qt_user]

Будет-то будет, но код в котором даже все операции атомарны может успешно рухнуть - потому что др нитка может вклиниться между операциями. Простой пример

Код

C++ (Qt)
int a. b;
..
if (a == b) 
 a = 0;
 b = 100;
}
 

Здесь все атомарно, но тем не менее придется это место защищать блокировкой. Начиная от момента когда выполнилось a == b до момента когда выполнится a = 0 могло произойти многое, др нитка(и) могли изменить  a и b как они хотели.

Пасиба, это мы усвоили

[Igors]

Пасиба, это мы усвоили

Ну то так кажется - на эти грабли наступают все и много-много раз 

[JamS007]

1. void QThread::sleep ( unsigned long secs )

лучше эту:
void QThread::yieldCurrentThread () [static]

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

[qt_user]

1. void QThread::sleep ( unsigned long secs )

лучше эту:
void QThread::yieldCurrentThread () [static]

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

не очень понимаю смысл этой ф-ции.. эта ф-ция просто передает управление другому потоку на один квант времени? то есть
отдает 1 свой квант другому потоку?

В чем тогда разница QThread::yieldCurrentThread () и QThread::sleep("1 квант времени")?

[JamS007]

qt_user
yieldCurrentThread() передаст управление другой нити, и тем самым прекратит выполнение первой. Отличие от sleep() состоит в том, что в следующий раз поток будет "разбужен" когда этого захочет планировщик, а не по истечению интервала времени.

из доки:
void QThread::sleep ( unsigned long secs ) [static protected]
Forces the current thread to sleep for secs seconds.

1. Нет никаких гарантий, что функция sleep() приведет к передаче управления другому потоку. Гипотетически - так должно быть, и наверное так часто и есть, но все-же.
2. Вы не сможете указать функции sleep() квант времени меньше 1 секунды, да есть msleep() но там Вы не сможете указать квант времени меньше 1 милисекунды.
3. sleep() только запускает механизм, который будет проверять прошел ли заданный промежуток времени или нет. Ничего не сказано о том, как эта проверка осуществляться. Она может выполниться 1 раз (через указанный промежуток времени) или 10 раз... Соответственно, за каждым разом будут потрачены ресурсы системы на сопоставление текущего времени с намеченным для пробуждения. В Вашем случае можно сэкономить эти затраты, ведь у вас уже есть условие, к которому можно привязаться (блокировка по мьютексу, а не точное время).

Я даже встречал негативные отзывы в сторону boost::thread за функцию sleep(). Там она реализована таким образом, что сопоставляет время системы с запланированным для пробуждения, и если в ОС сменить время, к примеру, на день назад, то поток будет разбужен через день+интервал времени, заданный функции sleep(). Подозреваю, что в Qt также.

[qt_user]

HaySayCheese
Спасибо большое, а то я много слышал что sleep плохо, но не видел да и не понимал как работает yieldCurrentThread()
насчет пункта 2. есть еще QThread::usleep ( unsigned long usecs ) для микросекунд

[BRE]

HaySayCheese
Спасибо большое, а то я много слышал что sleep плохо, но не видел да и не понимал как работает yieldCurrentThread()

Ну скорее sleep плохо не потому, что он не передает (или передает) управление другому потоку, а в неэффективности самого ожидания.
Например, поток ожидает какие-то данные и пока их нет засыпает на одну секунду. Данные могут придти в любой момент, т.е. поток проверил и заснул, а в этот момент данные появились, поток все равно будет спать секунду, а только потом проснется и обнаружит данные для обработки, хотя могу бы уже секунду как работать.
Поэтому, лучше использовать специальные механизмы, которые могут пробудить поток в тот момент, когда данные появились, например, условные переменные (QWaitCondition).

[thechicho]

я чтобы сделать паузу в потоках, делал как-то так

.h потока
public:
    bool условие;
поток::run()
{
QEventLoop loopPause;

if (условие) {
connect(this, SIGNAL(pause()), &loopPause, SLOT(quit()));
loopPause.exec();
}

}

слот потока::blabla()
{
    emit pause();
}

слот главного потока::клик_на_мышку_пауза()
{
    if(поток->условие) {
        поток->условие = false;
        emit pause();
    } else {
        поток->условие = true;
    }
}

слот главного потока::создаем_потоки()
{
     for (int i = 0; i < 100500; i++) {
         класспотока *поток = new класспотока(this);
         поток->условие = false;
         connect(this, SIGNAL(pause()), поток, SLOT(blabla()));
         поток->погнали!;
     }
}

потом раскидывал
if (условие) {
connect(this, SIGNAL(pause()), &loopPause, SLOT(quit()));
loopPause.exec();

перед затратными по времени операциями и усе.
запускал по 500 потоков, работало все ч0тко.)

[thechicho]

а не чуток по-другому, ща глянул.

при создании потоков
connect(this, SIGNAL(pauseThreadTrueSignal()), thread, SLOT(pauseThreadTrueSlot()));
connect(this, SIGNAL(pauseThreadFalseSignal()), thread, SLOT(pauseThreadFalseSlot()));

connect(ui->pushButtonStart, SIGNAL(clicked()), this, SLOT(pauseSlot()));

void гуи поток::pauseSlot()
{
    if (isIconPlay) {
        emit pauseThreadTrueSignal();
    } else {
        emit pauseThreadFalseSignal();
    }
}



void поток::pauseThreadTrueSlot()
{
    //qDebug() << "pauseThread: true";
    pauseThread = true;
    if (workManual)
        emit labelStatusSignal("Пауза");
}

void поток::pauseThreadFalseSlot()
{
    //qDebug() << "pauseThread: false";
    pauseThread = false;
    emit pauseDisabledSignal();    
    if (workManual)
        emit labelStatusClearSignal();
}

if (pauseThread) {
     connect(this, SIGNAL(pauseDisabledSignal()), &loopPause, SLOT(quit()));
     loopPause.exec();
}

isIconPlay - эт условие в гуи потоке (bool). я картинку делал прост, тип play, pause (еще и stop делал).
короче работало все на ура. я хз, нафик заморачиваться с атомарными операциями, если так проще и работает без проблем. но дело ваше, конечно