Форум программистов, компьютерный форум, киберфорум
С++ для начинающих
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 5.00/6: Рейтинг темы: голосов - 6, средняя оценка - 5.00
1 / 1 / 2
Регистрация: 13.12.2011
Сообщений: 81

Как задать скорость обработки операций в потоке std::thread?

19.09.2014, 13:23. Показов 1176. Ответов 10
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Процесс задается при помощи параметра «скорость обработки» - n операций в миллисекунду.
Подскажите как это реализовать.
0
IT_Exp
Эксперт
34794 / 4073 / 2104
Регистрация: 17.06.2006
Сообщений: 32,602
Блог
19.09.2014, 13:23
Ответы с готовыми решениями:

Std::thread. Почему можно обращаться к приватным членам объекта в другом потоке?
#include <iostream> #include <thread> #include <mutex> #include <iomanip> using namespace std; class TestThread{ public:...

Как убить std::thread?
К сожалению мне так и не удалось найти информацию о том, как корректно убить std::thread в случае необходимости. Как правило, предлагают...

Использование std::function в std::thread
Нужно вызвать function fnc в новом потоке. Как сделать? function <void(vector<char>)> fnc; void test(vector<char> data) { ...

10
Эксперт по математике/физикеЭксперт С++
 Аватар для Ilot
2224 / 1426 / 420
Регистрация: 16.05.2013
Сообщений: 3,646
Записей в блоге: 6
19.09.2014, 13:58
Примерно так:
C++
1
2
3
4
5
6
std::future<int> ft = async(my_thread);
//Помещаем следующий код в цикл
if(ft.wait_for(std::chrono::milliseconds(1000 / n)) == std::future_status::ready)
    ft = async(my_thread);
else
    //Тут можно обработать как будет отзываться ваша программа если выполнение инструкций превышает допустимый диапазон
2
1 / 1 / 2
Регистрация: 13.12.2011
Сообщений: 81
20.10.2014, 22:18  [ТС]
C++
1
2
3
4
5
6
7
8
9
10
11
12
class Cores{
    public:
        Cores();
        ~Cores();
        bool Is_Busy();
        void Set_Limit_Of_Core(int );
        int Get_Limit_Of_Core();
        void Execute_Task(CallbackType );
    private:
        std::future<int> ft;
        int Limit_Of_Core; //operations per second.
    };
C++
1
2
3
4
5
6
bool Cores::Is_Busy(){
    if(ft.wait_for(std::chrono::milliseconds(1)) == std::future_status::ready)
        return true;
    else
        return false;
}
На 2 строчке
C++
1
if(ft.wait_for(std::chrono::milliseconds(1)) == std::future_status::ready)
вылетает с ошибкой:
Необработанное исключение по адресу 0x76152F71 в CS_Labs.exe: исключение Microsoft C++: std::future_error по адресу памяти 0x0064F480.
0
Эксперт по математике/физикеЭксперт С++
 Аватар для Ilot
2224 / 1426 / 420
Регистрация: 16.05.2013
Сообщений: 3,646
Записей в блоге: 6
21.10.2014, 08:54
А вы асинхронную процедуру запустили?
C++
1
std::future<int> ft = async(my_thread);//<-- запускаем процедуру
Только обязательно проверяйте, что бы флаг статуса не был равен deferrend:
C++
1
2
3
if(ft.wait_for(std::chrono::seconds(0)) != std::future_status::deferrend) {
    /** Обрабатываем фъючерс */
}
1
21.10.2014, 10:19

Не по теме:

Ilot, deferred все же.
И async в таком уж случае лучше звать через async(fun, std::launch::async);

0
1 / 1 / 2
Регистрация: 13.12.2011
Сообщений: 81
21.10.2014, 11:36  [ТС]
Да, запустил...Забыл упомянуть.

C++
1
2
3
void Cores::Execute_Task(CallbackType our_task){    
    ft = std::async(our_task);
}
0
Эксперт по математике/физикеЭксперт С++
 Аватар для Ilot
2224 / 1426 / 420
Регистрация: 16.05.2013
Сообщений: 3,646
Записей в блоге: 6
21.10.2014, 11:43
i7otep9wka, приведите весь код.
0
1 / 1 / 2
Регистрация: 13.12.2011
Сообщений: 81
21.10.2014, 11:54  [ТС]
Я понимаю, что вы от меня хотите.
Вот меин.
Запускаю в этой строчке:
C++
1
Core1.Execute_Task(MyTasks.get_elem());
Но проверка результата идет раньше:
C++
1
2
if ((Core1.Is_Busy() != true) && (MyTasks.Is_empty() != true))
            Core1.Execute_Task(MyTasks.get_elem());
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
57
58
59
60
61
62
63
64
65
66
67
68
69
int main(){
    Cores Core1;
    Cores Core2;
    Cores Core3;
    Cores Core4;
    Cores Core5;
 
    Tasks MyTasks;
 
    Core1.Set_Core_Perfomance(5);
    Core2.Set_Core_Perfomance(1);
    Core3.Set_Core_Perfomance(1);
    Core4.Set_Core_Perfomance(1);
    Core5.Set_Core_Perfomance(1);
 
    //making tasks
    for (int i=1;i<=10000;i++){
        int Random_Difficulty=(rand() % 5 +1);
        MyTasks.Set_Difficulty_Of_Task(Random_Difficulty);
        MyTasks.Task_Generator();
    }
 
    //waiting cores become FREE
    while (
        (
        Core1.Is_Busy() &&
        Core2.Is_Busy() &&
        Core3.Is_Busy() &&
        Core4.Is_Busy() &&
        Core5.Is_Busy()
        )
        == true)
    {
    };
 
    //test variable;
    long z = 0;
 
    //executing tasks on cores
    while (MyTasks.Is_empty() != true)
    {
        if ((Core1.Is_Busy() != true) && (MyTasks.Is_empty() != true))
            Core1.Execute_Task(MyTasks.get_elem());
        if ((Core2.Is_Busy() != true) && (MyTasks.Is_empty() != true))
            Core2.Execute_Task(MyTasks.get_elem());
        if ((Core3.Is_Busy() != true) && (MyTasks.Is_empty() != true))
            Core3.Execute_Task(MyTasks.get_elem());
        if ((Core4.Is_Busy() != true) && (MyTasks.Is_empty() != true))
            Core4.Execute_Task(MyTasks.get_elem());
        if ((Core5.Is_Busy() != true) && (MyTasks.Is_empty() != true))
            Core5.Execute_Task(MyTasks.get_elem());
        ++z;
    }
 
 
 
//Simple get elements from Queue.
    /*
 
 
    for (int i=1;i<=10;i++){
        CallbackType myfunc = MyTasks.get_elem();
        myfunc();
    }
    */
    std::cout << "RESULT is: "<< z << std::endl;
    getchar();
    return 0;
}
И именно для такого случая мне нужен статус "std::future_status::deferrend"
Я уже не помню, что вчера сделал. Но сегодня оно скомпилировалось.
Только я не могу понять, правильно ли оно работает.
**весь-весь код не помещается.
0
Эксперт по математике/физикеЭксперт С++
 Аватар для Ilot
2224 / 1426 / 420
Регистрация: 16.05.2013
Сообщений: 3,646
Записей в блоге: 6
21.10.2014, 12:05
i7otep9wka, здесь вопрос не компиляции. У вас запуск асинхронной процедуры происходит позже проверки фъючерса. Правильно будет сперва запустить асинхронный поток. Убедится, что он не отложен и лишь затем узнавать его статус. Запуск можно выполнять например так:
C++
1
std::future<int> ft = async(std::launch::async, my_thread);//<-- запускаем процедуру сейчас
1
1 / 1 / 2
Регистрация: 13.12.2011
Сообщений: 81
21.10.2014, 13:17  [ТС]
1. добавил ft = async(std::launch::async, my_thread);
2. сделан асинхронный поток до всех проверок фьючерса.

C++
1
2
3
4
5
6
7
8
9
bool Cores::Is_Busy(){
    if (ft.wait_for(std::chrono::seconds(60)) == std::future_status::ready){
        std::cout << "FREE" << std::endl;
        return false;
    }
    else{
        std::cout << "BUSY" << std::endl;
        return true;
    }
Учитывая задержку в минуту, поток должен обрабатывать задание каждые 60 секунд
по такой схеме:
C++
1
2
3
4
5
6
//executing tasks on cores
    while (MyTasks.Is_empty() != true)
    {
        if ((Core1.Is_Busy() != true) && (MyTasks.Is_empty() != true))
            Core1.Execute_Task(MyTasks.get_elem());
}
А он все задания выполнят меньше чем за секунду.
0
В астрале
Эксперт С++
 Аватар для ForEveR
8049 / 4806 / 655
Регистрация: 24.06.2010
Сообщений: 10,562
21.10.2014, 13:28
i7otep9wka, Где задержка на 60 секунд?
Задержку можно добавить используя thread sleep или если действительно задание занимает большое время. wait_for же указывается максимальное время ожидания, если в течении данного времени возвращается результат - статус становится ready.

http://en.cppreference.com/w/c... e/wait_for
Там же есть неплохой пример.
1
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
BasicMan
Эксперт
29316 / 5623 / 2384
Регистрация: 17.02.2009
Сообщений: 30,364
Блог
21.10.2014, 13:28
Помогаю со студенческими работами здесь

Std::thread как усыпить/ пробудить поток?
Есть ли в std::thread возможность как - то приостановить поток, не разрушая его, а потом, по какому - то сигналу / прерыванию - возобновить...

Ошибка компиляции "no instance of constructor 'std::thread::thread' matches the argument list"
Не могу сообразить почему возникает ошибка. У меня в классе есть метод, который должен работать в нескольких потоках одновременно. Вот он: ...

Boost::thread std::thread
чем отличается boost::thread( ) от std::thread (с++17)? я спрашиваю не о способе реализации потоков в целом, а конкретно о этих функциях....

Boost::thread vs std::thread
Доброго времени суток, решил углубить свои знания, и решил почитать про потоки, бустовые и те что в 11 стандарте приняли, с бустом все ясно...

Thread.Sleep в главном потоке или как сделать нормальную задержку
Здравствуйте, мне нужно сделать задержку, хотелось бы через Thread.Sleep, но использование его в UI-потоке, как известно, приводит к...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
11
Ответ Создать тему
Новые блоги и статьи
SDL3 для Web (WebAssembly): Реализация движения на Box2D v3 - трение и коллизии с повёрнутыми стенами
8Observer8 20.02.2026
Содержание блога Box2D позволяет легко создать главного героя, который не проходит сквозь стены и перемещается с заданным трением о препятствия, которые можно располагать под углом, как верхнее. . .
Конвертировать закладки radiotray-ng в m3u-плейлист
damix 19.02.2026
Это можно сделать скриптом для PowerShell. Использование . \СonvertRadiotrayToM3U. ps1 <path_to_bookmarks. json> Рядом с файлом bookmarks. json появится файл bookmarks. m3u с результатом. # Check if. . .
Семь CDC на одном интерфейсе: 5 U[S]ARTов, 1 CAN и 1 SSI
Eddy_Em 18.02.2026
Постепенно допиливаю свою "многоинтерфейсную плату". Выглядит вот так: https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=11617&stc=1&d=1771445347 Основана на STM32F303RBT6. На борту пять. . .
Камера Toupcam IUA500KMA
Eddy_Em 12.02.2026
Т. к. у всяких "хикроботов" слишком уж мелкий пиксель, для подсмотра в ESPriF они вообще плохо годятся: уже 14 величину можно рассмотреть еле-еле лишь на экспозициях под 3 секунды (а то и больше),. . .
И ясному Солнцу
zbw 12.02.2026
И ясному Солнцу, и светлой Луне. В мире покоя нет и люди не могут жить в тишине. А жить им немного лет.
«Знание-Сила»
zbw 12.02.2026
«Знание-Сила» «Время-Деньги» «Деньги -Пуля»
SDL3 для Web (WebAssembly): Подключение Box2D v3, физика и отрисовка коллайдеров
8Observer8 12.02.2026
Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами и вызывать обработчики событий столкновения. . . .
SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL_LoadPNG (без SDL3_image)
8Observer8 11.02.2026
Содержание блога Библиотека SDL3 содержит встроенные инструменты для базовой работы с изображениями - без использования библиотеки SDL3_image. Пошагово создадим проект для загрузки изображения. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru