boost::thread (2 стр) / Общее / Форум / Программирование игр / GameDev.ru

Нет, i это число шагов апгрейда каждого класса. Просто повторный вызов функции. А k это число экземпляров.

Der FlugSimulator
Постоялец

#16
20:42, 16 фев 2025

nop90h
> вообще это похоже на кривой thread pool

Больше похоже на использование околослучайного подбора под решение задачи.
А беда в том, что и задача толком не сформулирована.

__sergey
Постоялец

#17
21:21, 16 фев 2025

Funtik

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

Der FlugSimulator
Постоялец

#18
21:52, 16 фев 2025

__sergey
> не пересоздавая объект ... Но я не знаю его.

Pool pattern?

vka123
Постоялец

#19
22:37, 16 фев 2025

вообще если планируете работать с многопоточкой то всё-таки надо написать свой пул потоков.
штука полезная.
и лучше написать этот пул самому - будете понимать как работает и сможете сделать дополнительный интересный функционал типа threadaffinity, NUMA и прочего. и С++ тут не поможет - придётся использовать API системы.

Zab
Постоялец

#20
3:01, 17 фев 2025

vka123
> вообще если планируете работать с многопоточкой то всё-таки надо написать свой пул потоков.
Это особенно важно под виндой, где потоки создаются кошмарно медленно. В юниксовых системах с этим проще, там можно потоки создавать на каждую разовую потребность.

Zab
Постоялец

#21
3:09, 17 фев 2025

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

nop90h
Постоялец

#22
6:07, 17 фев 2025

__sergey
> тобы был механизм вот так в цикле вызывать функцию в потоке не пересоздавая объект потока.
в бусте есть asio, там есть thread_pool
но я бы на твоем месте базу подтянул, потому что пока складывается впечатление, что ты слабо понимаешь, что ты вообще делаешь.

Zab
> Да еще и дедлоков наверняка нахватаешь повсюду.
мне кажется, чел вообще не вкурсе, что нужна синхронизация

nop90h
Постоялец

#23
6:37, 17 фев 2025

Zab
> Это особенно важно под виндой, где потоки создаются кошмарно медленно. В юниксовых системах с этим проще, там можно потоки создавать на каждую разовую потребность.
хмм, по моему и там и там это долго.
т.к. это системный вызов, причем не тривиальный.
откуда инфа, что в винде медленней ?

__sergey
Постоялец

#24
9:27, 17 фев 2025

nop90h
> мне кажется, чел вообще не вкурсе, что нужна синхронизация
Да ладно, я метод сопряженных градиентов на вычислительных шейдерах делал. Попробуйте там группы синхронизировать. Могли бы просто посоветовать как это с пулом сделать. Задача-то вродете перь ясна. Просто псевдокод какой-нибудь.

nop90h
Постоялец

#25
9:36, 17 фев 2025

__sergey
сперва надо избавиться от каши в голове.
и ответить себе (не мне) на вопрос, а занешь ли ты вообще, что такое канкаренси, что такое дата рэйс, зачем нужны примитивы синхронизации как из множества примитивов выбрать тот, который подходит тебе.
Если ответа на этот вопрос нет, то в многопоточность пока лезть не стоит.
Вот неплохой курс:
https://www.youtube.com/watch?v=zw6V3SDsXDk&list=PL4_hYwCyhAva37l… BcKRELso5nvBm

что касается asio thread_pool, то прямо в документации к нему есть пример
https://think-async.com/Asio/boost_asio_1_26_0/doc/html/boost_asi… ead_pool.html

__sergey
Постоялец

#26
9:47, 17 фев 2025

nop90h
Это я все понимаю. Сейчас вопрос не об этом. Представим, что потоки не обращаются ни к каким общим данным. Мне надо разобраться с функциями буста. Просто вотэтот цикл с классами он в оконной процедуре выполняется, то есть в message loop еще вот этот цикл с потоками надо сделать. Пока работает только тот простой вариант. Надо чтобы примерно намекнули как с пулом делать

nop90h
Постоялец

#27
10:13, 17 фев 2025

__sergey
> Мне надо разобраться с функциями буста
ну вот же, прямо в примере, в ссылке, которую кидал на доку по thread_pool

// Submit a lambda object to the pool.
boost::asio::post(pool,
    []()
    {
      ...
    });

в лямбде захватываешь shared_ptr на инстанс и вызваешь из лямбды метод инстанса

Mephistopheles
Постоялец

#28
13:39, 17 фев 2025

сколько нужно программистов чтобы выполнить функцию в отдельном потоке?)

у Funtik в https://gamedev.ru/code/forum/?id=288761&page=2&m=6024878#m18
Рабочий код(логика), переделай его на буст и будет тебе счастье
Если конечно тебе не нужно чтобы все потоки работали с общими данными на запись, в этом случае рекомендую вообще отказаться от многопоточки.

fake.pdf
Удалён

#29
14:19, 17 фев 2025

Задал вопрос deepseek, вот что выдал:

+ Показать

− Скрыть

#include <vector>
#include <queue>
#include <iostream>

#ifdef _WIN32
#include <windows.h>
#else
#include <pthread.h>
#include <unistd.h>
#endif

class ThreadPool {
public:
    ThreadPool(size_t numThreads);
    ~ThreadPool();
    void enqueue(void (*task)(void*), void* arg);

private:
    struct Task {
        void (*function)(void*);
        void* argument;
    };

    std::vector<void*> threads;
    std::queue<Task> tasks;

#ifdef _WIN32
    HANDLE mutex;
    HANDLE condition;
    static DWORD WINAPI threadFunction(LPVOID lpParam);
#else
    pthread_mutex_t mutex;
    pthread_cond_t condition;
    static void* threadFunction(void* arg);
#endif

    bool stop;
    void executeTask();
};

ThreadPool::ThreadPool(size_t numThreads) : stop(false) {
#ifdef _WIN32
    mutex = CreateMutex(NULL, FALSE, NULL);
    condition = CreateEvent(NULL, FALSE, FALSE, NULL);
#else
    pthread_mutex_init(&mutex, NULL);
    pthread_cond_init(&condition, NULL);
#endif

    for (size_t i = 0; i < numThreads; ++i) {
#ifdef _WIN32
        HANDLE thread = CreateThread(NULL, 0, threadFunction, this, 0, NULL);
        threads.push_back(thread);
#else
        pthread_t thread;
        pthread_create(&thread, NULL, threadFunction, this);
        threads.push_back((void*)thread);
#endif
    }
}

ThreadPool::~ThreadPool() {
    stop = true;

#ifdef _WIN32
    SetEvent(condition);
    for (size_t i = 0; i < threads.size(); ++i) {
        WaitForSingleObject((HANDLE)threads[i], INFINITE);
        CloseHandle((HANDLE)threads[i]);
    }
    CloseHandle(mutex);
    CloseHandle(condition);
#else
    pthread_cond_broadcast(&condition);
    for (size_t i = 0; i < threads.size(); ++i) {
        pthread_join((pthread_t)threads[i], NULL);
    }
    pthread_mutex_destroy(&mutex);
    pthread_cond_destroy(&condition);
#endif
}

void ThreadPool::enqueue(void (*task)(void*), void* arg) {
#ifdef _WIN32
    WaitForSingleObject(mutex, INFINITE);
#else
    pthread_mutex_lock(&mutex);
#endif

    Task t;
    t.function = task;
    t.argument = arg;
    tasks.push(t);

#ifdef _WIN32
    ReleaseMutex(mutex);
    SetEvent(condition);
#else
    pthread_mutex_unlock(&mutex);
    pthread_cond_signal(&condition);
#endif
}

#ifdef _WIN32
DWORD WINAPI ThreadPool::threadFunction(LPVOID lpParam) {
    ThreadPool* pool = (ThreadPool*)lpParam;
    pool->executeTask();
    return 0;
}
#else
void* ThreadPool::threadFunction(void* arg) {
    ThreadPool* pool = (ThreadPool*)arg;
    pool->executeTask();
    return NULL;
}
#endif

void ThreadPool::executeTask() {
    while (!stop) {
#ifdef _WIN32
        WaitForSingleObject(mutex, INFINITE);
        while (tasks.empty() && !stop) {
            ReleaseMutex(mutex);
            WaitForSingleObject(condition, INFINITE);
            WaitForSingleObject(mutex, INFINITE);
        }
#else
        pthread_mutex_lock(&mutex);
        while (tasks.empty() && !stop) {
            pthread_cond_wait(&condition, &mutex);
        }
#endif

        if (stop) {
#ifdef _WIN32
            ReleaseMutex(mutex);
#else
            pthread_mutex_unlock(&mutex);
#endif
            break;
        }

        Task task = tasks.front();
        tasks.pop();

#ifdef _WIN32
        ReleaseMutex(mutex);
#else
        pthread_mutex_unlock(&mutex);
#endif

        task.function(task.argument);
    }
}

// Пример использования
void exampleTask(void* arg) {
    int* value = (int*)arg;
    std::cout << "Task executed with value: " << *value << std::endl;
    delete value;
}

int main() {
    ThreadPool pool(4);

    for (int i = 0; i < 10; ++i) {
        int* value = new int(i);
        pool.enqueue(exampleTask, value);
    }

    // Даем время на выполнение задач
#ifdef _WIN32
    Sleep(1000);
#else
    sleep(1);
#endif

    return 0;
}