VPF::boost::mutex - Форум программистов

JanryMayers

Дата 24.1.2011, 00:43 (ссылка)

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

Загрузка ...

Шустрый

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

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

Здрастье всем!

При решении определённой задачи возник, вопрос необходимо ли использовать mutex, если да то можете объяснить как будет работать программа с ним и без него?

Задача:
Основной поток запускает x вспомогательных, бесконечно добавляющих в некий контейнер свой элемент, потоков с некоторой изменяющейся задержкой. При этом он удаляет самый старый элемент в случае, если тот был добавлен другим потоком или если количество элементов в контейнере >Y (вот эта часть условия не ясна до конца).

вот кусок кода

Код


class mThread{
public:
    mThread(size_t, size_t, std::list<int>*);
    ~mThread();
    void stop();
private:
    void run();
    boost::shared_ptr<boost::thread> m_thread;
    boost::thread* the_thread;
    std::list<int>* List;
    size_t Y;
    size_t element;
    bool signal;
};
mThread::mThread(size_t x, size_t y, std::list<int>* l) : element(x), Y(y), List(l), signal(true){
    m_thread = boost::shared_ptr<boost::thread>(new boost::thread(boost::bind(&mThread::run, this)));
}

void mThread::run(){
    while(signal){
        if(static_cast<size_t>(List->size()) > Y){
            List->pop_front();
            std::cout<<"\nthread "<<element<<"pop_front";
        }
        else{
            List->push_back(element);
            std::cout<<"\nthread "<<element<<"push_back";
        }
    }
}
mThread::~mThread(){
}
void mThread::stop(){
    signal = false;
    m_thread->join();
}

подскажите что нужно добавить в метод run?

Это сообщение отредактировал(а) JanryMayers - 24.1.2011, 01:38

borisbn

Дата 24.1.2011, 09:47 (ссылка)

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

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 4875
Регистрация: 6.2.2010
Где: Ростов-на-Дону

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

А где же ?

Цитата(JanryMayers @ 24.1.2011, 00:43

)

При этом он удаляет самый старый элемент в случае, если тот был добавлен другим потоком

Для синхронизации между потоками в твоём случае я бы передавал в потоки не просто указатель на list, а на класс-наследник от list, который бы включал в себя ещё 2 метода - lock и unlock, а также private-член mutex.
Тогда run() выглядел бы след.образом

Код


void mThread::run(){
    while(signal){
        List->lock();
        int lastElem = List.front();
        if(static_cast<size_t>(List->size()) > Y
          || lastElem != element ) // то самое условие, о котором я говорил в начале поста
       {
            List->pop_front();
            std::cout<<"\nthread "<<element<<"pop_front";
        }
        else{
            List->push_back(element);
            std::cout<<"\nthread "<<element<<"push_back";
        }
        List->unlock();
    }
}

Ну, а что должны делать ф-ции lock/unlock - думаю понятно.

И ещё. Правильнее было бы написать конструктор так:

Код


mThread::mThread(size_t x, size_t y, std::list<int>* l)
  : element(x),
     Y(y),
     List(l),
     signal(true),
     m_thread( new boost::thread(boost::bind(&mThread::run, this)) );
{
}

Ну, и раз уж пошла такая пьянка ... smile

Я бы передавал не указатель, а ссылку на list

--------------------

Женщины отличаются от программистов тем, что у них чары состоят из стрингов

JanryMayers

Дата 24.1.2011, 11:57 (ссылка)

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

Загрузка ...

Шустрый

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

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

Спасибо, borisbn. Добавил бы те в репутацию, но постов малавата).

То есть получается mutex должен быть один единственный на все потоки. А какое у него должно быть начальное значение?
И на счет функций lock/unlock:

Код


cclass Case : public std::list<size_t> {
public:
    Case();
    ~Case();
    void lock();
    void unlock();
private:
    mutable boost::mutex the_mutex;
};
void Case::lock(){
    boost::mutex::scoped_lock lock(the_mutex);
}
void Case::unlock(){
    boost::mutex::scoped_lock unlock(the_mutex);
}

я правильно мысль уловил?

...

Цитата

Я бы передавал не указатель, а ссылку на list

почему? объясни, приведи пример)
у мя щас выглядит так

Код


typedef mThread* mThreadPtr;
int main(int argc , char*argv[] ){
...
    Case the_case;
    mThreadPtr* thrd = new mThreadPtr[X];
    for(size_t i = 0; i<X; i++){
        thrd[i] = new mThread(i+1, Y, &the_case);
    }
...
}

и ещё варнинг warning C4355: 'this' : used in base member initializer list
на m_thread( new boost::thread(boost::bind(&mThread::run, this)) );

Это сообщение отредактировал(а) JanryMayers - 24.1.2011, 11:58

azesmcar

Дата 24.1.2011, 13:16 (ссылка)

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

Загрузка ...

uploading...

Профиль
Группа: Участник Клуба
Сообщений: 6291
Регистрация: 12.11.2004
Где: Армения

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

Цитата(JanryMayers @ 24.1.2011, 11:57

)

То есть получается mutex должен быть один единственный на все потоки

да.

Цитата(JanryMayers @ 24.1.2011, 11:57

)

А какое у него должно быть начальное значение?

какое есть. конструктор по умолчанию все сделает.

Цитата(JanryMayers @ 24.1.2011, 11:57

)

я правильно мысль уловил?

Цитата(JanryMayers @ 24.1.2011, 11:57

)

void Case::lock(){
boost::mutex::scoped_lock lock(the_mutex);
}

эффект этой функции - 0!

и еще..надо стараться блокировать как можно меньший участок кода.
В частности, если код выглядет вот так

Цитата(borisbn @ 24.1.2011, 09:47

)

void mThread::run(){
    while(signal){
        List->lock();
        int lastElem = List.front();
        if(static_cast<size_t>(List->size()) > Y
          || lastElem != element ) // то самое условие, о котором я говорил в начале поста
       {
            List->pop_front();
            std::cout<<"\nthread "<<element<<"pop_front";
        }
        else{
            List->push_back(element);
            std::cout<<"\nthread "<<element<<"push_back";
        }
        List->unlock();
    }
}

то смысл использования потоков мне не совсем понятен, все равно все выполняется последовательно.

Добавлено через 1 минуту и 51 секунду
да, и тема тут не совсем в правильном разделе, попрошу ка я модераторов перенести ее в "Общие Вопросы".

borisbn

Дата 24.1.2011, 13:53 (ссылка)

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

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 4875
Регистрация: 6.2.2010
Где: Ростов-на-Дону

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

Цитата(JanryMayers @ 24.1.2011, 11:57

)

Я бы передавал не указатель, а ссылку на listпочему? объясни, приведи пример)

просто мне ссылки больше нравятся. Ты не сможешь передать нулевой указатель (ссылки на 0 не бывает) и тебе, соответственно, не нужно всё время проверять
if ( ptr != 0 ) { ptr-> ...

Цитата(azesmcar @ 24.1.2011, 13:16

)

и еще..надо стараться блокировать как можно меньший участок кода.В частности, если код выглядет вот так

полностью на 100% согласен. просто в коде, представленном ТС, по другому никак. Плюс его программа, скорее всего, либо для обучения потокам и мьютексам, либо она гораздо больше и сложнее, а в том коде lock'ать необходимо, т.к. там front(), size(), pop_front() и push_back() идут непосредственно др.за др.

Цитата(azesmcar @ 24.1.2011, 13:16

)

смысл использования потоков мне не совсем понятен, все равно все выполняется последовательно.

если это - и вся программа, то да, никакого смысла.

Цитата(JanryMayers @ 24.1.2011, 11:57

)

я правильно мысль уловил?

посмотри у boost::mutex должны быть ф-ции типа lock/unlock.
и ещё, в данном конкретном случае модификатор mutable IMHO бессмысленный, тем более, что ф-ции твоего класса Case не константные

--------------------

Женщины отличаются от программистов тем, что у них чары состоят из стрингов

JanryMayers

Дата 24.1.2011, 16:26 (ссылка)

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

Загрузка ...

Шустрый

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

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

Цитата

нет, классы scoped_lock, unique_lock, shared_lock... и так далее нужны для безопасности исключений. В частности scoped_lock заблокирует мьютекс в конструкторе и разблокирует в деструкторе, т.е.

Цитата(JanryMayers @ 24.1.2011, 11:57 )
void Case::lock(){
boost::mutex::scoped_lock lock(the_mutex);
}

эффект этой функции - 0!

теперь правильно?

Код


class Case : public std::list<size_t> {
public:
    Case();
    ~Case();
    void lock();
    void unlock();
private:
    boost::mutex the_mutex;
};
Case::Case(){
}
Case::~Case(){
}
void Case::lock(){
    the_mutex.lock();
}
void Case::unlock(){
    the_mutex.unlock();
}

Цитата

то смысл использования потоков мне не совсем понятен, все равно все выполняется последовательно.

задача у мя такая.

Цитата

и еще..надо стараться блокировать как можно меньший участок кода.

тогда лучше в этом куске кода каждое обращение к Case обработать mutex'ом

Цитата

int lastElem = List.front();
if(static_cast<size_t>(List->size()) > Y

если у мя пустой список как я могу от него взять первый элемент?!!

Это сообщение отредактировал(а) JanryMayers - 24.1.2011, 16:30

borisbn

Дата 24.1.2011, 16:34 (ссылка)

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

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 4875
Регистрация: 6.2.2010
Где: Ростов-на-Дону

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

Цитата(JanryMayers @ 24.1.2011, 16:26

)

теперь правильно?

ага

Цитата(JanryMayers @ 24.1.2011, 16:26

)

тогда лучше в этом куске кода каждое обращение к Case обработать mutex'ом

у тебя и так идёт обращение в каждой строке:

Код


int lastElem = List->front();                   // 1
if(static_cast<size_t>(List->size()) > Y // 2
          || lastElem != element ) 
       {
            List->pop_front();                    // 3
        }
        else{
            List->push_back(element);        // 4

--------------------

Женщины отличаются от программистов тем, что у них чары состоят из стрингов

JanryMayers

Дата 24.1.2011, 17:49 (ссылка)

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

Загрузка ...

Шустрый

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

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

все таки странное условие, если я его правильно понял то

Код


void mThread::run(){
    while(signal){
        the_case_in_thread->lock();
        if(static_cast<size_t>(the_case_in_thread->size()) >= Y ||((!the_case_in_thread->empty())&&(the_case_in_thread->front()!= element))){
            the_case_in_thread->pop_front();
        }
        else{
            the_case_in_thread->push_back(element);
        }
        the_case_in_thread->unlock();
    }
}

контейнер будет всегда состоять из одного элемента? О_о
а то и вообще пустой

Это сообщение отредактировал(а) JanryMayers - 24.1.2011, 17:51

borisbn

Дата 24.1.2011, 18:16 (ссылка)

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

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 4875
Регистрация: 6.2.2010
Где: Ростов-на-Дону

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

Цитата(JanryMayers @ 24.1.2011, 17:49

)

все таки странное условие

задание то тебе ставили - тебе и разбираться smile

Цитата(JanryMayers @ 24.1.2011, 17:49

)

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

Цитата(JanryMayers @ 24.1.2011, 00:43

)

бесконечно добавляющих в некий контейнер свой элемент, потоков с некоторой изменяющейся задержкой

если у первого потока задержка 10 сек, а второго одна, и они кладут элементы "1" и "2" соответственно, то в контейнере будет много 2-ек и мало единиц ( или вообще единиц не будет)

и ещё. почему у тебя добавление элемента по else от удаления? Насколько я понял должно быть
ЕСЛИ НУЖНО УДАЛИТЬ
{
УДАЛИТЬ;
}
ДОБАВИТЬ;

--------------------

Женщины отличаются от программистов тем, что у них чары состоят из стрингов

azesmcar

Дата 24.1.2011, 21:53 (ссылка)

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

Загрузка ...

uploading...

Профиль
Группа: Участник Клуба
Сообщений: 6291
Регистрация: 12.11.2004
Где: Армения

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

Цитата(JanryMayers @ 24.1.2011, 16:26

)

тогда лучше в этом куске кода каждое обращение к Case обработать mutex'ом

Мьютексом ничего не обрабатывается. Вкратце опишу работу мьютексов.

Мьютекс - объект, имеющий минимум 2 функции - lock() и unlock(). Мьютекс может быть заблокирован одним потоком только один раз (есть и рекурсивные мьютексы, но это другой вопрос). Если мьютекс заблокирован одним потоком, то другой поток при попытке блокировке будет ждать, пока первый его не разблокирует. Таким образом мьютексы обеспечивают последовательность выполнения в параллельном мире. Т.е. часть своей функции ты можешь выполнить НЕ параллельно, а последовательно. Это значит, что эту часть кода (ту, что находиться между lock() и unlock() может выполнить одновременно лишь один поток. Следовательно, если вся функция находиться в критической секции, то и смысла использовать потоки нет, с тем же успехом эта функция может быть вызвана в цикле (вру, не с тем же, циклом будет оптимальнее).

Надеюсь понятно описал.

Цитата(JanryMayers @ 24.1.2011, 16:26

)

теперь правильно?

В принципе да, но
1. от std::list наследовать не стоит, он для этого не предназначен.
2. зачем нужны функции lock() и unlock()? класс (раз уж он потокобезопасен) сам должен понимать когда нужно блокировать мьютекс а когда разблокировать, от пользователя это должно быть скрыто.

Это сообщение отредактировал(а) azesmcar - 24.1.2011, 22:37

JanryMayers

Дата 25.1.2011, 01:54 (ссылка)

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

Загрузка ...

Шустрый

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

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

спасибо за описание

Цитата

1. от std::list наследовать не стоит, он для этого не предназначен.

а что посоветуете вместо std::list??
или его просто использовать в объект класса Case

Код


void mThread::run(){
        the_case_in_thread->lock();
        while(signal){
            if(static_cast<size_t>(the_case_in_thread->size()) >= Y ||((!the_case_in_thread->empty())&&(the_case_in_thread->front()!= element))){
            the_case_in_thread->pop_front();
        }
    the_case_in_thread->push_back(element);
        the_case_in_thread->unlock();
    }
}

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

Это сообщение отредактировал(а) JanryMayers - 25.1.2011, 03:28

azesmcar

Дата 25.1.2011, 06:20 (ссылка)

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

Загрузка ...

uploading...

Профиль
Группа: Участник Клуба
Сообщений: 6291
Регистрация: 12.11.2004
Где: Армения

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

Цитата(JanryMayers @ 25.1.2011, 01:54

)

а что посоветуете вместо std::list??

Вместо list - ничего, list хорош, но вместо наследования могу посоветовать композицию.
Вообще если браться за задачу правильно, то чтобы сделать лист потокобезопасным его нужно написать самому (можно и на основе стандартного, но попотеть придется).
Тогда это позволит блокировать минимум кода, приведу пример.
Список (std::list) - это структура, которая имеет ссылки на предыдущий и следующий элемент
previous_node <-- node --> next_node
каждая структура к тому же хранит значение.

Сейчас, чтобы добавить элемент в список ты блокируешь весь список, выбора у тебя нет, хотя это тебе и не нужно.
На самом деле, если ты добавляешь элемент в конец списка, другие потоки могут спокойно читать, удалять и добавлять в начало, но в случае полного блокирования этого не будет. Можно решить этот вопрос, если к примеру создавать мьютекс для каждого элемента (накладно, но и тут есть решение) и при работе с конкретным элементом блокировать только его, и его соседей. Это просто пример.

Цитата(JanryMayers @ 25.1.2011, 01:54

)

        the_case_in_thread->lock();
        while(signal){
            if(static_cast<size_t>(the_case_in_thread->size()) >= Y ||((!the_case_in_thread->empty())&&(the_case_in_thread->front()!= element))){
            the_case_in_thread->pop_front();
        }
    the_case_in_thread->push_back(element);
        the_case_in_thread->unlock();

если между lock и unlock выскочит исключение будет deadlock. Используй boost::scoped_lock.

Это сообщение отредактировал(а) azesmcar - 25.1.2011, 08:03

borisbn

Дата 25.1.2011, 10:03 (ссылка)

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

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 4875
Регистрация: 6.2.2010
Где: Ростов-на-Дону

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

Цитата(JanryMayers @ 25.1.2011, 01:54

)

void mThread::run(){
        the_case_in_thread->lock();
        while(signal) {
...
            the_case_in_thread->unlock();
          }
}
вот такой код вроде работает как нужно.

в данном случае у тебя вообще неправильно должно работать, т.к. локируешь ты ДО цикла, а разлокируешь ВНУТРИ. Т.е. если придерживаться этого варианта, а не того, что советует azesmcar (кстати - правильного, но более тяжеловесного), то должно быть как-то так

Код


void mThread::run() {
    while(signal) {
        the_case_in_thread->lock();
        if ( static_cast<size_t>(the_case_in_thread->size()) >= Y ||
             ( (!the_case_in_thread->empty()) && (the_case_in_thread->front()!= element) ) ) {
            the_case_in_thread->pop_front();
        }
        the_case_in_thread->push_back(element);
        the_case_in_thread->unlock();
// а вот здесь нужно поставить задержку, чтобы
// 1. выполнить условие задачи - "... потоков с некоторой изменяющейся задержкой"
// 2. не было бы этого: "только при вводе с клавиатуры при работе потоков, нужно немного ждать, что бы они завершились"
// как в boost сделать sleep не знаю. погугли
    }
}

Это сообщение отредактировал(а) borisbn - 25.1.2011, 10:04

--------------------

Женщины отличаются от программистов тем, что у них чары состоят из стрингов

JanryMayers

Дата 25.1.2011, 10:18 (ссылка)

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

Загрузка ...

Шустрый

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

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

Цитата

с некоторой изменяющейся задержкой

её что нужно рендомить?... если да, то в каком диапозоне, лучше всего?

Цитата

mThread::mThread(size_t x, size_t y, std::list<int>* l)
  : element(x),
     Y(y),
     List(l),
     signal(true),
     m_thread( new boost::thread(boost::bind(&mThread::run, this)) );
{
}

и что делать с этим this? он у мя варнинг сыпет
warning C4355: 'this' : used in base member initializer list

Это сообщение отредактировал(а) JanryMayers - 25.1.2011, 10:21

borisbn

Дата 25.1.2011, 14:33 (ссылка)

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

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 4875
Регистрация: 6.2.2010
Где: Ростов-на-Дону

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

Цитата(JanryMayers @ 25.1.2011, 10:18

)

её что нужно рендомить?

повторю

Цитата(borisbn @ 24.1.2011, 18:16

)

задание то тебе ставили - тебе и разбираться

что означает фраза

Цитата(JanryMayers @ 25.1.2011, 10:18

)

с некоторой изменяющейся задержкой

в задании, которое тебе ставили - я не знаю

по поводу warning'a - вообще-то от них необходимо избавляться, но в данном конкретном случае его (C4355) можно отключить, т.к. в стандарте сказано:

Цитата

Names in the expression-list of a mem-initializer are evaluated in the scope of the constructor for which the mem-
initializer is speciﬁed. [ Example:
class X {
int a;
int b;
int i;
int j;
public :
const int & r;
X( int i): r(a), b(i), i(i), j(this ->i ) {}
};
initializes X::r to refer to X::a, initializes X::b with the value of the constructor parameter i, initializes X::i with the
value of the constructor parameter i, and initializes X::j with the value of X::i; this takes place each time an object of
class X is created. —end example ] [Note: because the mem-initializer are evaluated in the scope of the constructor, the
this pointer can be used in the expression-list of a mem-initializer to refer to the object being initialized. —end note ]

а boost::bind 100% не будет "refer to the object" being они initialized или не being

--------------------

Женщины отличаются от программистов тем, что у них чары состоят из стрингов

JanryMayers

Дата 26.1.2011, 12:23 (ссылка)

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

Загрузка ...

Шустрый

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

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

вообщем остановился на таком варианте что скажите?

Код


void mThread::run(){ 
    while(signal){
        if(the_case_in_thread->size() > Y ||
            ((!the_case_in_thread->empty())&&(the_case_in_thread->front()!= element))){
            the_case_in_thread->pop_front();
        }
    the_case_in_thread->push_back(Y, element);
    //сюда ещё добавлю boost::thread::sleep
    }
}

а вот класс с мьютексом

Код


class the_case{
public:
    the_case();
    ~the_case();
    void lock();
    void unlock();
    std::list<size_t>* get_list();
    size_t size();
    bool empty();
    size_t front();
    void pop_front();
    void push_back();
    void push_back(size_t,size_t);
private:
    std::list<size_t> the_list;
    boost::mutex the_mutex;
};
the_case::the_case(){
}
the_case::~the_case(){
}
std::list<size_t>* the_case::get_list(){
    return &the_list;
}
size_t the_case::size(){
    std::cout<<"\nin_size";
    boost::mutex::scoped_lock lock(the_mutex);
    return the_list.size();
}
bool the_case::empty(){
    std::cout<<"\nin_empty";
    boost::mutex::scoped_lock lock(the_mutex);
    return the_list.empty();
}
size_t the_case::front(){
    std::cout<<"\nin_front";
    boost::mutex::scoped_lock lock(the_mutex);
    return the_list.front();
}
void the_case::pop_front(){
    std::cout<<"\nin_pop_front";
    if(!empty()){
        boost::mutex::scoped_lock lock(the_mutex);
        the_list.pop_front();
        std::cout<<"\npop_front";
        lock.unlock();
    }
}
void the_case::push_back(size_t Y,size_t element){
    if(size()<Y){
        boost::mutex::scoped_lock lock(the_mutex);
        the_list.push_back(element);
        std::cout<<"\npush_back "<<element;
        lock.unlock();
    }
}

Это сообщение отредактировал(а) JanryMayers - 26.1.2011, 12:45

azesmcar

Дата 26.1.2011, 14:06 (ссылка)

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

Загрузка ...

uploading...

Профиль
Группа: Участник Клуба
Сообщений: 6291
Регистрация: 12.11.2004
Где: Армения

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

JanryMayers

Первое, что заметил.

Цитата(JanryMayers @ 26.1.2011, 12:23

)

size_t front();
void pop_front();

Это ошибка, так нельзя. Да, в обычной ситуации функции front() и pop_front() лучше разделять, так-как они выполняют две задачи, к тому же сделать функцию, выполняющую более одной задачи строго-безопасной в отношении исключений довольно сложно. Но это другой случай. В данный момент перед тобой стоит задача получения элемента в многопотоной среде, с таким раскладом ты можешь получить один элемент с помощью функции front(), потом вытащить элемент с помощью функции pop_front(), но нет никакой гарантии, что ты вытащил именно тот элемент, который получил до этого, так-как между двумя вызовами этих функций другой поток может вставить значение в список и ты удалишь этот элемент даже не зная о нем. Функция pop_front() потокобезопасного списка должна возвращать значение, которое она вытащила. Если нужна строгая безопасность исключений (хотя сомневаюсь) возвращай shared_ptr.

borisbn

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

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

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 4875
Регистрация: 6.2.2010
Где: Ростов-на-Дону

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

и ещё. Ты проверяешь, например в первом потоке

Цитата

if ( !the_case_in_thread->empty() ...

потом второй поток может влезть и удалить последний элемент, а потом первый поток будет делать

Цитата

the_case_in_thread->pop_front()

первое, что приходит в голову, это весь код "бизнесс-логики" засунуть в класс Case и защитить его mutex'ом

Код


void Case:doIt( int Y, int element )
{
        boost::mutex::scoped_lock lock(the_mutex);
        if( the_list.size() > Y ||
            ((!the_list.empty())&&(the_list.front()!= element))){
            the_list.pop_front();
        }
    the_list.push_back(element);
}

а код потока станет таким

Код


void mThread::run() {
    while(signal){
        the_case_in_thread->doIt( Y, element );
        boost::thread::sleep( ??? );
    }
}

это мало чем отличается от варианта, где lock вызывается в потоке в самом начале, а unlock в конце, зато все потокобезопасные вещи инкапсулированы от пользователя.

вариант, конечно, так себе, но всё должно работать...

--------------------

Женщины отличаются от программистов тем, что у них чары состоят из стрингов

JanryMayers

Дата 28.1.2011, 05:48 (ссылка)

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

Загрузка ...

Шустрый

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

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

понятно

я вот нашел такую вещь

SharedLockable Concept

void lock_shared()
bool try_lock_shared()
bool timed_lock_shared(boost::system_time const& abs_time)
void unlock_shared()

тут есть и тайм лок можно использовать вместо sleep?

а также возможно написать mThread::run(), используя try/catch?

azesmcar

Дата 28.1.2011, 06:11 (ссылка)

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

Загрузка ...

uploading...

Профиль
Группа: Участник Клуба
Сообщений: 6291
Регистрация: 12.11.2004
Где: Армения

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

Цитата(JanryMayers @ 28.1.2011, 05:48

)

SharedLockable Concept

SharedLockable не имеет отношения к timed lock-у, для этого можно просто использовать timed_mutex, но зачем он тебе? timed_lock не аналог sleep-а. smile

Зачем тебе вообще sleep?

JanryMayers

Дата 28.1.2011, 10:25 (ссылка)

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

Загрузка ...

Шустрый

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

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

Условие задачи такое

Цитата

Основной поток запускает x вспомогательных, бесконечно добавляющих в некий контейнер свой элемент, потоков с некоторой изменяющейся задержкой.

хотел изменяющуюся задержку реализовать sleep и mt19937 генератором... , но думаю есть способ по правильнее, чем этот

Цитата

SharedLockable не имеет отношения к timed lock-у

почему? может я тебя не правильно понял, но вот тут написано что какое то отношение он все таки имеет, по крайней мере функция time_lock_shared

azesmcar

Дата 28.1.2011, 10:46 (ссылка)

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

Загрузка ...

uploading...

Профиль
Группа: Участник Клуба
Сообщений: 6291
Регистрация: 12.11.2004
Где: Армения

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

Цитата(JanryMayers @ 28.1.2011, 10:25

)

Ну "какое-то" далекое отношение, по сути shared не для этого ввели, а для shared ownership-а, т.е. для timed_lock-а есть TimedLockable.
http://www.boost.org/doc/libs/1_32_0/doc/h...epts.TimedMutex.
Но все равно, это не то, что тебе нужно.

Цитата(JanryMayers @ 28.1.2011, 10:25

)

что такое "с некоторой изменяющейся задержкой"? Мне эта часть непонятна

Цитата

некоторой изменяющейся

random-ом что ли? хотя в любом случае это sleep.

JanryMayers

Дата 29.1.2011, 14:22 (ссылка)

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

Загрузка ...

Шустрый

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

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

да рендом. я его(sleep) так написал

Код


void the_thread::sleep(){
    gen.seed(static_cast<unsigned> (std::time(0)));

    const size_t NANOSECONDS_PER_MILLISECOND = 1000000;

        boost::normal_distribution<double> norm_dist(0, 5);
        boost::variate_generator<boost::mt19937&, boost::normal_distribution<double>> normal_sampler(gen, norm_dist);

    size_t rand = boost::lexical_cast<size_t>(normal_sampler());

    boost::xtime the_time;

    the_time.sec = 0;
    the_time.nsec = rand*NANOSECONDS_PER_MILLISECOND;

    m_thread->sleep(the_time);
}

правда в строчке

Код


    size_t rand = boost::lexical_cast<size_t>(normal_sampler());

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

в этом классе

Код


class the_case{
public:
    the_case();
    ~the_case();
    void lock();
    void unlock();
    std::list<size_t>* get_list();
    size_t size();
    bool empty();
    size_t front();
    void pop_front();
    void push_back();
    void push_back(size_t,size_t);
private:
    std::list<size_t> the_list;
    boost::mutex the_mutex;
};

говорят, что нельзя выдавать указатель на данные под mutex'ом в этой строчке

Код


    std::list<size_t>* get_list();

const std::list<size_t>* the_case::get_list(){
    return &the_list;
}

какой выход из такой ситуации?

Это сообщение отредактировал(а) JanryMayers - 30.1.2011, 18:49

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