Hi

Существует ли бесплатная кросс-платформенная (сейчас нужны win + linux) библиотека для работы с потоками и синхронизации (нужны критические секции и события)?

Спасибо!

Здравствуйте, csharper, Вы писали:

C>Hi

C>Существует ли бесплатная кросс-платформенная (сейчас нужны win + linux) библиотека для работы с потоками и синхронизации (нужны критические секции и события)?

C>Спасибо!
в boost вроде threadы были( www.boost.org ) может это тоже....

Здравствуйте, LuciferMoscow, Вы писали:

LM>Здравствуйте, csharper, Вы писали:

C>>Hi

C>>Существует ли бесплатная кросс-платформенная (сейчас нужны win + linux) библиотека для работы с потоками и синхронизации (нужны критические секции и события)?

C>>Спасибо!
LM>в boost вроде threadы были( www.boost.org ) может это тоже....

Ага, я смотрел. Но что-то не нашел ивентов

Здравствуйте, csharper, Вы писали:

C>Ага, я смотрел. Но что-то не нашел ивентов

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

А если серьезно, то в POSIX системах нет events. Есть как раз таки condition variables.

csharper wrote:

> Hi
>
> Существует ли бесплатная кросс-платформенная (сейчас нужны win + linux) библиотека для работы с потоками и синхронизации (нужны критические секции и события)?

boost::thread. Только тебе придется забыть про event и освоить condition variables.

http://rsdn.ru/Forum/?mid=638679

Автор: MaximE
Дата: 13.05.04

http://rsdn.ru/Forum/?mid=1021046

Автор: MaximE
Дата: 11.02.05

--
Maxim Yegorushkin

Здравствуйте, CrystaX, Вы писали:

CX>Здравствуйте, csharper, Вы писали:
C>>Ага, я смотрел. Но что-то не нашел ивентов
CX>Сейчас придет Максим Егорушкин и скажет, что ну их нафиг, эти убогие виндовые events, лучше использовать condition variables.
CX>Это я не в качестве наезда (ни на Егорушкина, ни на condition variables).
CX>А если серьезно, то в POSIX системах нет events. Есть как раз таки condition variables.
Не знаю кто такие condition variables, но они могут работать в разных процессах?

Здравствуйте, LuciferMoscow, Вы писали:

LM>Не знаю кто такие condition variables, но они могут работать в разных процессах?

Насколько я знаю, да. Только при этом они должны находиться в разделяемой процессами памяти.

LuciferMoscow wrote:

[]

> Не знаю кто такие condition variables,

bad for you

> но они могут работать в разных процессах?

POSIXные могут. boost::thread не предоставляет такого функционала, т.к. он не был бы доступен на не POSIX платформах.

--
Maxim Yegorushkin

Здравствуйте, CrystaX, Вы писали:

CX>Здравствуйте, LuciferMoscow, Вы писали:

LM>>Не знаю кто такие condition variables, но они могут работать в разных процессах?

CX>Насколько я знаю, да. Только при этом они должны находиться в разделяемой процессами памяти.

И должен быть установлен аттрибут PTHREAD_PROCESS_SHARED

Здравствуйте, MaximE, Вы писали:

ME>LuciferMoscow wrote:
ME>[]
> Не знаю кто такие condition variables,
ME>bad for you
очень информатвно

Здравствуйте, csharper, Вы писали:

C>Hi

C>Существует ли бесплатная кросс-платформенная (сейчас нужны win + linux) библиотека для работы с потоками и синхронизации (нужны критические секции и события)?

C>Спасибо!
Гугль рулез форева
Кроме Boost::Thread, который вероятно войдет в Стандарт C++ кстати :
ZThread
OpenThreads
Common C++(не только триды)
С++ portable components
Сюда в общем загляни.

Здравствуйте, Mr.Chipset, Вы писали:

MC>Здравствуйте, csharper, Вы писали:

C>>Hi

C>>Существует ли бесплатная кросс-платформенная (сейчас нужны win + linux) библиотека для работы с потоками и синхронизации (нужны критические секции и события)?

C>>Спасибо!
MC>Гугль рулез форева

+1 (http://www.google.com/Top/Computers/Programming/Languages/C%2B%2B/Class_Libraries/?il=1)

MC>Кроме Boost::Thread, который вероятно войдет в Стандарт C++ кстати :
MC>ZThread
MC>OpenThreads
MC>Common C++(не только триды)
MC>С++ portable components
MC>Сюда в общем загляни.

Еще ACE (ну нравиться мне эта штука, хоть и большая она), APR, wxBase. В этих трех библиотеках не только многопоточность, но и много другого вкусного.

Здравствуйте, Mr.Chipset, Вы писали:

MC>Кроме Boost::Thread, который вероятно войдет в Стандарт C++ кстати :

А может и не войдет
http://lists.boost.org/boost/2005/05/25846.php

Здравствуйте, alnsn, Вы писали:

A>Здравствуйте, Mr.Chipset, Вы писали:

MC>>Кроме Boost::Thread, который вероятно войдет в Стандарт C++ кстати :

A>А может и не войдет
A>http://lists.boost.org/boost/2005/05/25846.php

Тогда, в принципе не стоит считать это преимуществом и начать поиски лучшей библиотеки

ME>boost::thread. Только тебе придется забыть про event и освоить condition variables.
А можно вкратце что сие есть таке?

Здравствуйте, Tom, Вы писали:

ME>>boost::thread. Только тебе придется забыть про event и освоить condition variables.
Tom>А можно вкратце что сие есть таке?

Механизм ожидания наступления определенного события.
Вот: здесь, здесь

Здравствуйте, csharper, Вы писали:

C>Ага, я смотрел. Но что-то не нашел ивентов
Event можно рассматривать как семафор, max count которого равен единице. Комбинируя мьютекс и семафор ты можешь "руками" сделать аналог эвента.
В своё время я так поступал, вариант Виндовс/Линукс. Посмотри, может пригодится .

/------------------------------------------------------------
// Event, i.e. semaphore which maxcount == 1
//------------------------------------------------------------
class Event
{    
public:
    Event()
    {
        #ifdef WIN32
            event_ = ::CreateEvent(0, FALSE, FALSE, 0);
        #else
            ::sem_init(&event_, 0, 0);
        #endif
    }

    ~Event()
    {
        #ifdef WIN32
            ::CloseHandle(event_);
        #else
            ::sem_destroy(&event_);
        #endif
    }

    void signal()
    {
        #ifdef WIN32
            ::SetEvent(event_);
        #else
            Guard guard(mutex_);
            int value;
            ::sem_getvalue(&event_, &value);
            if( !value )
                ::sem_post(&event_);
        #endif
    }

    bool wait(uint time)
    {
        #ifdef WIN32
            return ::WaitForSingleObject(event_, time) == WAIT_OBJECT_0;
        #else
            timespec tm;
            tm.tv_sec  =  time / 1000;
            tm.tv_nsec = (time % 1000) * 1000000;
            return !::sem_timedwait(&event_, &tm);
        #endif
    }

    bool check()
    {
        #ifdef WIN32
            return ::WaitForSingleObject(event_, 0) == WAIT_OBJECT_0;
        #else
            return !::sem_trywait(&event_);
        #endif
    }

private:
    sem_t  event_;
#ifndef WIN32
    Mutex  mutex_;   
#endif
};

//------------------------------------------------------------
// Mutex class
//------------------------------------------------------------
class Mutex
{
public:
    Mutex()
    {
        #ifdef WIN32
            ::InitializeCriticalSection(&mutex_);
        #else
            ::pthread_mutex_init(&mutex_, 0);            
        #endif        
    }

    ~Mutex()
    {
        #ifdef WIN32
            ::DeleteCriticalSection(&mutex_);
        #endif
    }

    void lock()
    {
        #ifdef WIN32
            ::EnterCriticalSection(&mutex_);
        #else
            ::pthread_mutex_lock(&mutex_);
        #endif
    }

    bool trylock() // true if mutex is free
    {
        #ifdef WIN32
            return !!::TryEnterCriticalSection(&mutex_);
        #else
            return !::pthread_mutex_trylock(&mutex_);
        #endif
    }
    
    void unlock()
    {
        #ifdef WIN32
            ::LeaveCriticalSection(&mutex_);
        #else
            ::pthread_mutex_unlock(&mutex_);
        #endif
    }

private:
    pthread_mutex_t mutex_;
};

//------------------------------------------------------------
// Auto protection class
//------------------------------------------------------------
class Guard
{
public:
    Guard(Mutex& m) : mutex_(m) { mutex_.lock(); }
    ~Guard() { mutex_.unlock(); }

private:
    Mutex&   mutex_;
};

Да, в начале нужно вот ещё чего добавить.

#ifdef WIN32
    #include <windows.h>

    typedef CRITICAL_SECTION    pthread_mutex_t;
    typedef HANDLE              sem_t;

#else
    #include <pthread.h>
    #include <semaphore.h>

#endif

Вроде всё.

Вдогонку на всякий случай хочу заметить, что не стоит оптимизировать класс Event, и вместо пары семафор-мьютекс использовать только один мьютекс. Изначально я так и хотел поступить поскольку мьютекс можно рассматривать как бинарный семафор. Но беда в том что posix mutex должен быть разблокирован тем же потоком, каким он был заблокирован. Это довольно существенное ограничение .

Здравствуйте, csharper, Вы писали:

C>Hi

C>Существует ли бесплатная кросс-платформенная (сейчас нужны win + linux) библиотека для работы с потоками и синхронизации (нужны критические секции и события)?

C>Спасибо!

The ADAPTIVE Communication Environment (ACE(TM))
http://www.cs.wustl.edu/~schmidt/ACE.html

есть все это, плюс многое другое. кросс-платформенная и бесплатная. хорошо документированная, есть даже книжка на русском языке в стиле Getting Startes.

Здравствуйте, Amethyst, Вы писали:

В коде Eventа у Вас ошибка в линуксовой части в методе wait. Должно быть так

timespec tm;
tm.tv_sec  =  ::time(0) + time / 1000;
tm.tv_nsec = (time % 1000) * 1000000;

return !::sem_timedwait(&event_, &tm);

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