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

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

W>>Просто добавь ключевое слове thread_local:

MTD>Это еще зачем? Просто создать новый объект уже не модно?

Добавить одно ключевое слово намного проще.

Но если хочешь самостоятельно управлять этими объектами, то, разумеется, можешь делать и так. Просто, судя по ответу автора в соседней ветке

Автор: prrt
Дата: 16.01.18

, это всё же чуть более сложное действие.

Как известно, boost::random не является thread safe.
Тогда если глобально есть

boost::random::mt19937 gen(42);

И из разных потоков одновременно очень часто вызывать

uint32_t randVal = gen();

то что может произойти?

Я вижу 2 опасности:
1) Для одновременных вызовов всегда будут сгенерированы одинаковые значения;
2) Произойдет undefined behaviour и вызов либо "зависнет", либо вывалится с segmentation fault.

Моя задача — с максимальной производительностью получать псевдо-случайные числа от gen.min() до gen.max(), качество чисел не важно. Поэтому без нужны закрывать мьютексом не хотелось бы.

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

W>Просто добавь ключевое слове thread_local:
W>

thread_local boost::random::mt19937 gen;

Да, это, похоже, то, что нужно. Только вот компилятор старый, thread_local не поддерживает. Поковырялся с boost::thread_specific_ptr, не вышло, или ошибки при компиляции, или на этапе выполнения.
В итоге сделал пока так:
Глобально

std::map<boost::thread::id, boost::random::mt19937> gens;

При создании потоков:

    for (std::size_t i = 0; i < thread_pool_size_; ++i)
    {
        boost::shared_ptr<boost::thread> thread(new boost::thread(
              boost::bind(&boost::asio::io_service::run, io_service_ptr)));
        gens[thread->get_id()] =  boost::random::mt19937(i);
    }

И сама генерация случайного числа в обработчике Asio:

uint rand = gens[boost::this_thread::get_id()]();

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

P>В итоге сделал пока так:
P>Глобально
P>

P>std::map<boost::thread::id, boost::random::mt19937> gens;
P>

P>При создании потоков:
P>

P>    for (std::size_t i = 0; i < thread_pool_size_; ++i)
P>    {
P>        boost::shared_ptr<boost::thread> thread(new boost::thread(
P>              boost::bind(&boost::asio::io_service::run, io_service_ptr)));
P>        gens[thread->get_id()] =  boost::random::mt19937(i);
P>    }
P>

P>И сама генерация случайного числа в обработчике Asio:
P>

P>uint rand = gens[boost::this_thread::get_id()]();
P>

Если качество чисел не важно, но нужна потокобезопасность, не проще ли использовать rand_s под Windows или rand_r под UNIX?

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

P>Моя задача — с максимальной производительностью получать псевдо-случайные числа от gen.min() до gen.max(), качество чисел не важно. Поэтому без нужны закрывать мьютексом не хотелось бы.

Что мешает просто иметь в каждом потоке свой генератор? Просто добавь ключевое слове thread_local:

thread_local boost::random::mt19937 gen;

Ну и по желанию инициализируй эти генераторы не константой, а комбинацией из времени и номера потока.

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

P>Моя задача — с максимальной производительностью получать псевдо-случайные числа от gen.min() до gen.max()

Максимально быстро — иметь в каждом потоке свой генератор.

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

W>Просто добавь ключевое слове thread_local:

Это еще зачем? Просто создать новый объект уже не модно?

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

MTD>Максимально быстро — иметь в каждом потоке свой генератор.

В каждом потоке свой генератор далеко не очевидно, как сделать. Потоки — это boost::thread из асинхронного http сервера boost::asio. Свой генератор для каждого Connection — это легко, но смысла в данном случае не имеет (большое число соединений, в т.ч. короткоживущих).

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

P>В каждом потоке свой генератор далеко не очевидно, как сделать.

А в чем сложность? Пишешь примерно так:

auto gen = RandomGenerator();

И используешь.

P>Потоки — это boost::thread из асинхронного http сервера boost::asio.

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

P>Свой генератор для каждого Connection — это легко, но смысла в данном случае не имеет (большое число соединений, в т.ч. короткоживущих).

И что? Если они короткоживущие, то любой конект убъет все твои оптимизации. Да и для keep-alive соединений генератор случайных чисел будет последнее что надо оптимизировать.

Понимаешь, точка синхронизации, даже неявная в виде, например, shared_ptr переданного по значению приводит к тому, что твои потоки и ядра процессора начинают простаивать. Перед тем как синхронизировать потоки надо 2 раза подумать, а надо ли?

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

AN>Если качество чисел не важно, но нужна потокобезопасность, не проще ли использовать rand_s под Windows или rand_r под UNIX?
Судя по ответу на этот вопрос — https://stackoverflow.com/questions/29465758/correct-way-to-use-rand-r-for-multithreaded-programs-in-c-c, для rand_r (у меня Linux) нужно делать seed из каждого потока. Т.е. всё-равно получается похожий огород...

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

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

P>Судя по ответу на этот вопрос — https://stackoverflow.com/questions/29465758/correct-way-to-use-rand-r-for-multithreaded-programs-in-c-c, для rand_r (у меня Linux) нужно делать seed из каждого потока. Т.е. всё-равно получается похожий огород...

int myrnd()
{
    unsigned int init;
    init ^= pthread_self() ^ time( NULL );

    return rand_r( &init );
}

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

P>Судя по ответу на этот вопрос — https://stackoverflow.com/questions/29465758/correct-way-to-use-rand-r-for-multithreaded-programs-in-c-c, для rand_r (у меня Linux) нужно делать seed из каждого потока. Т.е. всё-равно получается похожий огород...

rand_r здорово быстрее твистера Мерсенна, если тебе качество чисел не важно.

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

P>Моя задача — с максимальной производительностью получать псевдо-случайные числа от gen.min() до gen.max(), качество чисел не важно. Поэтому без нужны закрывать мьютексом не хотелось бы.

Делаешь пул из десятка генераторов. Сид каждого генератора инициализируешь его номером в пуле. Каждый генератор в пуле защищаешь мьютексом. В нитках используешь генератор под номером thread_id % 10. Так вероятность коллизий будет маленьклй.

PS 10 взято для примера и может быть любым.