Количество QThread потоков ограничено Опции

[alle-gro]

Привет всем,
столкнулся с неприятным явлением. Не могу получить больше чем 999 одновремено работающих потоков.
999 - это для потоков, которые не имеют очередь своих сообщений. Для потоков с очередью (тип exec()) - лимит 996.
От количества памяти на компьютере не зависит. Нашел статью, где говорится что в Windows можно открыть 2000 потоков на 1 процесс, почему в Qt в половину меньше, кто-нибудь знает ответ на этот вопрос?

Вот взял код и Qt примеров:

#include <QtCore>

#include <stdio.h>
#include <stdlib.h>

//! [0]
const int DataSize = 10;
const int BufferSize = 8192;

QSemaphore freeBytes(BufferSize);
QSemaphore usedBytes;
//! [0]

//! [1]
class Producer : public QThread
//! [1] //! [2]
{
public:
    void run();
    Producer(){m_exit = false;}
    static int count;
    void stop(){m_exit = true;}
    bool m_exit;
};
 
int Producer::count = 0;

void Producer::run()
{
    
    //fprintf(stderr, "\n %p started", this); 
    //QCoreApplication::processEvents();
    count ++;
    
    char buffer[BufferSize];
    qsrand(QTime(0,0,0).secsTo(QTime::currentTime()));
   // while (!m_exit) {
    //    msleep(1000);
        //fprintf(stderr, "%d", i); 
        //freeBytes.acquire();
        //buffer[i % BufferSize] = "ACGT"[(int)qrand() % 4];
        //usedBytes.release();
   // }
   exec();
    fprintf(stderr, "\n%p finished", this); 
    count --;
}
//! [2]

//! [3]
/*
class Consumer : public QThread
//! [3] //! [4]
{
public:
    void run();
};

void Consumer::run()
{
    for (int i = 0; i < DataSize; ++i) {
        usedBytes.acquire();
        fprintf(stderr, "%c", buffer[i % BufferSize]);
        freeBytes.release();
    }
    fprintf(stderr, "\n");
}
//! [4]
*/
//! [5]
#define THREAD_LIMIT 1100


int main(int argc, char *argv[])
//! [5] //! [6]
{
    QCoreApplication app(argc, argv);
    Producer *producer = new Producer[THREAD_LIMIT];
    //Consumer* consumer = new Consumer[1000];
    for(int i=0;i< THREAD_LIMIT; i++) {
        //producer[i].setStackSize (1* 100 );
        producer[i].start();

       }

    //consumer.start();
    quint64 k=0;
    while((Producer::count < THREAD_LIMIT)&& (k++ < 10000000)) {

        QCoreApplication::processEvents();
       }
        
    fprintf(stderr, "\n !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! %d\n", Producer::count);

    //consumer.wait();
    //for(int i=0;i< THREAD_LIMIT; i++) {
    //    producer[i].stop();
       //}
       
       for(int i=0;i< THREAD_LIMIT; i++) {
       producer[i].quit();
   }
       for(int i=0;i< THREAD_LIMIT; i++) {
        producer[i].wait();
   }
       fprintf(stderr, "\n ----------------------------------------- %d\n", Producer::count);
    delete[]  producer;
    return 0;
}
//! [6]

Не осуждайте за грязь, просто важен сам факт наличия ограничения.

[Litkevich Yuriy]

alle-gro, почитай вот эту тему: Boost thread - ограниченное количество потоков?, непонятное ограничение, не связанное с ресурсами системы
Там довольно основательное иследование.

[alle-gro]

alle-gro, почитай вот эту тему: Boost thread - ограниченное количество потоков?, непонятное ограничение, не связанное с ресурсами системы
Там довольно основательное иследование.

Да, спасибо за ссылку, однако, нашел там подтверджение тому, что уже видел.
Действительно кол-во потоков зависит от размера стэка для каждого потока, по-умолчанию в windows 1M.
Тогда, используя функцию setStackSize(), по-идее, я должен бы получить хоть какой-то результат. Но уменьшение стэка в Windows ни
к чему не привело. Здесь говорится, что в Linux- е можно как-то уменьшить размер стэка на поток, а вот что с Windows?

[ViGOur]

Здесь говорится, что в Linux- е можно как-то уменьшить размер стэка на поток, а вот что с Windows?

В видовс тоже можно, только это делается в реестре.
Смотри по ссылке выше, приведенной Litkevich Yuriy, мой 2 пост.

[alle-gro]

Здесь говорится, что в Linux- е можно как-то уменьшить размер стэка на поток, а вот что с Windows?

В видовс тоже можно, только это делается в реестре.
Смотри по ссылке выше, приведенной Litkevich Yuriy, мой 2 пост.

Да, большое спасибо, вижу, проверю, доложу о результатах

В видовс тоже можно, только это делается в реестре.
Смотри по ссылке выше, приведенной Litkevich Yuriy, мой 2 пост.

Перечитал еще раз утверждение, получается, что размером сека потока рулит только линковщик, через реестр другими величинами рулят.
Все сказанное в статье относится к VS.
А вот как рулить линковщиком в Qt, можно ли там ему указать меньший размер стека?
Думаю тот факт, что для VS рапортуют 2000 потоков, а в Qt это число 1000 и указывет, что default значение размера сека в Qt в 2 раза больше, выделяется, чем у VS проекта.

[Litkevich Yuriy]

линковщиком в Qt,

а в Qt нет линковщика.

[SABROG]

А вот как рулить линковщиком в Qt, можно ли там ему указать меньший размер стека?

ld --stack <size>
или
gcc -Wl,--stack=<size>

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

[alle-gro]

линковщиком в Qt,

а в Qt нет линковщика.

Не верю, не думаю, что Qt что то новое изобрели, это кто ж из obj файлов сшивает приложение, адреса функций раздает и.т.д ...
вот смотрю в make файл и вижу LINK = g++, что-то мне подсказывает, что это линкощик....

[AD]

Не верю, не думаю, что Qt что то новое изобрели, это кто ж из obj файлов сшивает приложение, адреса функций раздает и.т.д ...
вот смотрю в make файл и вижу LINK = g++, что-то мне подсказывает, что это линкощик....

Да, отдельно поставляемый компилятор. Например, из MINGW, или же из CYGWIN! Или вообще отдельный: g++, gcc, link, gdb!

[alle-gro]

Да, отдельно поставляемый компилятор. Например, из MINGW, или же из CYGWIN! Или вообще отдельный: g++, gcc, link, gdb!

А, ну это придирка , ... Я как-то Qt рассматриваю, как одно целое, начиная с 4.5. Оно даже IDE свое стало иметь, а компилятор, линковщик, дебаггер у нее, для windows, например, тоже рекомендованные из mingw пакета.