Потоки

@ReYalp · Регистрация: 27.12.2017

Студворк — интернет-сервис помощи студентам

Возможно как-то сделать так чтобы заранее созданный поток в котором уже выполняется какая-то функция после ее выполнения запустил уже другую функцию? Именно тот же самый поток

@oleg-m1973 · 16.12.2019, 16:30

Сообщение от ReYalp

Возможно как-то сделать так чтобы заранее созданный поток в котором уже выполняется какая-то функция после ее выполнения запустил уже другую функцию? Именно тот же самый поток

Пул потоков так и делает.
Функция потока будет одна, но в ней ты можешь вызывать любую другую функцию по указателю, либо по std::function, например

@ReYalp · 16.12.2019, 16:34 **[ТС]**

oleg-m1973, вот я и хочу реализовать свой пул , пока что я на стадии "понятия" как это все более-менее должно работать, есть рабочий но не очень сложный пример?

Добавлено через 1 минуту

Сообщение от oleg-m1973

Функция потока будет одна, но в ней ты можешь вызывать любую другую функцию по указателю, либо по std::function, например

если я правильно понял то в потоке запущенна функция в которой что-то по типу бесконечного цикла которая ждет на вход указатель на другую функцию которую нужно запустить?

@oleg-m1973 · 16.12.2019, 16:36

Сообщение от ReYalp

oleg-m1973, вот я и хочу реализовать свой пул , пока что я на стадии "понятия" как это все более-менее должно работать, есть рабочий но не очень сложный пример?

У меня вот здесь есть пример https://www.cyberforum.ru/blog... g5939.html

Добавлено через 1 минуту

Сообщение от ReYalp

если я правильно понял то в потоке запущенна функция в которой что-то по типу бесконечного цикла которая ждет на вход указатель на другую функцию которую нужно запустить?

Ну да, типа того. Только ждёт она события, что какой-то указатель на функцию валидный и можно забрать его и запустить.

@DrOffset · 16.12.2019, 16:38

Сообщение от ReYalp

если я правильно понял то в потоке запущенна функция в которой что-то по типу бесконечного цикла которая ждет на вход указатель на другую функцию которую нужно запустить?

По смыслу так и есть.
Обычно цикл все-таки не бесконечный, ожидание реализуется через примитивы синхронизации, например condition_variable или event. Поток ждет изменения в очереди операций\событий куда ставятся новые задачи или запрашивается завершение работы потока..

@ReYalp · 16.12.2019, 16:40 **[ТС]**

Сообщение от DrOffset

оток ждет изменения в очереди операций\событий куда ставятся новые задачи или запрашивается завершение работы потока..

тут можно использовать порт завершения ввода-вывода?

@DrOffset · 16.12.2019, 16:45

Сообщение от ReYalp

тут можно использовать порт завершения ввода-вывода?

Если вы про WIn32 Completion Ports, то да. Это собственно почти готовый механизм для организации пула потоков и постановки в него задач. Только это уже, конечно, не С++ будет.

@oleg-m1973 · 16.12.2019, 16:51

Сообщение от ReYalp

oleg-m1973, вот я и хочу реализовать свой пул , пока что я на стадии "понятия" как это все более-менее должно работать, есть рабочий но не очень сложный пример?

Схематично, вот так

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
class CThreadPool
{
public:
    CThreadPool()
    {
        for (size_t i = std::thread::hardware_concurrency(); i > 0; --i)
            m_threads.emplace_back(&CThreadPool::ThreadProc, this);
    }
 
    void Run(std::function<void()> fn)
    {
        std::unique_lock lock(m_mx);
        while (m_fn)
            m_cv.wait(lock);
 
        m_fn = std::move(fn);
        m_cv.notify_all();
    }
protected:
    std::function<void()> WaitFunc()
    {
        std::unique_lock lock(m_mx);
        while (!m_fn)
        {
            if (m_stop)
                return std::function<void()>();
 
            m_cv.wait(lock);
        }
        return std::move(m_fn);
        
    }
 
    void ThreadProc()
    {
        for (;;)
        {
            auto fn = WaitFunc();
            if (!fn)
                break;
 
            fn();
 
            std::lock_guard lock(m_mx);
            m_cv.notify_all();
        }
    }
 
    std::mutex m_mx;
    std::condition_variable m_cv;
 
    std::function<void()> m_fn;
    volatile bool m_stop = false;
 
    std::vector<std::thread> m_threads;
};

@ReYalp · 16.12.2019, 17:18 **[ТС]**

oleg-m1973, есть вопрос по Вашей реализации пула , откуда взялся тип CTaskRunner?

@oleg-m1973 · 16.12.2019, 17:19

Сообщение от ReYalp

oleg-m1973, есть вопрос по Вашей реализации пула , откуда взялся тип CTaskRunner?

Смотри там выше

@ReYalp · 16.12.2019, 17:20 **[ТС]**

oleg-m1973, все,нашел

Новые блоги и статьи Все статьи Все блоги /
Настройки VS Code Loafer 13.04.2026 { "cmake. configureOnOpen": false, "diffEditor. ignoreTrimWhitespace": true, "editor. guides. bracketPairs": "active", "extensions. ignoreRecommendations": true, . . .	Оптимизация кода на разграничение прав доступа к элементам формы Maks 13.04.2026 Алгоритм из решения ниже реализован на нетиповом документе, разработанного в конфигурации КА2. Задачи, как таковой, поставлено не было, проделанное ниже исключительно моя инициатива. Было так:. . .	Контроль заполнения и очистка дат в зависимости от значения перечислений Maks 12.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "ПланированиеПерсонала", разработанного в конфигурации КА2. Задача: реализовать контроль корректности заполнения дат назначения. . .	Архитектура слоя интернета для сервера-слоя. Hrethgir 11.04.2026 В продолжение https:/ / www. cyberforum. ru/ blogs/ 223907/ 10860. html Знаешь что я подумал? Раз мы все источники пишем в голове ветки, то ничего не мешает добавить в голову такой источник, который сам. . .
Подстановка значения реквизита справочника в табличную часть документа Maks 10.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "ПланированиеПерсонала", разработанного в конфигурации КА2. Задача: при выборе сотрудника (справочник Сотрудники) в ТЧ документа. . .	Очистка реквизитов документа при копировании Maks 09.04.2026 Алгоритм из решения ниже применим как для типовых, так и для нетиповых документов на самых различных конфигурациях. Задача: при копировании документа очищать определенные реквизиты и табличную. . .	модель ЗдравоСохранения 8. Подготовка к разному выполнению заданий anaschu 08.04.2026 https:/ / github. com/ shumilovas/ med2. git main ветка * содержимое блока дэлэй из старой модели теперь внутри зайца новой модели 8ATzM_2aurI	Блокировка документа от изменений, если он открыт у другого пользователя Maks 08.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа, разработанного в конфигурации КА2. Задача: запретить редактирование документа, если он открыт у другого пользователя. / / . . .

@ReYalp 63 / 46 / 11 Регистрация: 27.12.2017 Сообщений: 1,484

	Потоки 16.12.2019, 16:19. Показов 1099. Ответов 10 Метки нет (Все метки) Возможно как-то сделать так чтобы заранее созданный поток в котором уже выполняется какая-то функция после ее выполнения запустил уже другую функцию? Именно тот же самый поток 0

@ReYalp 63 / 46 / 11 Регистрация: 27.12.2017 Сообщений: 1,484
	16.12.2019, 17:18 [ТС]
	oleg-m1973, есть вопрос по Вашей реализации пула , откуда взялся тип CTaskRunner? 0

@ReYalp 63 / 46 / 11 Регистрация: 27.12.2017 Сообщений: 1,484
	16.12.2019, 17:20 [ТС]
	oleg-m1973, все,нашел 0

Потоки

Решение