Поток таймера петли - PullRequest
Новая
       20

Поток таймера петли

3 голосов
/ 28 мая 2019

Я хотел бы создать пул потоков для таймера цикла: для каждых n секунд мы будем запускать задачу.

В моем примере у нас есть две задачи. Для каждой задачи я создам один поток для запуска. Я добавляю условие статуса для каждой задачи, если статус false, мы ничего не делаем. Мне нужен статус для управления таймером, я могу вызвать запуск / останов таймера (извините, в этом коде есть только функция запуска).

Вот мой код: 

 #include <iostream>
#include <list>
#include <functional>
#include <map>
#include <thread>
#include <chrono>
#include <vector>
#include <mutex>

//using namespace std::chrono_literals;

void print_time()
{
    std::chrono::time_point<std::chrono::system_clock> now = std::chrono::system_clock::now();
    std::chrono::system_clock::duration tp = now.time_since_epoch();
    tp -= std::chrono::duration_cast<std::chrono::seconds>(tp);
    std::time_t ttp = std::chrono::system_clock::to_time_t(now);
    tm t = *gmtime(&ttp);

    std::printf("[%04u-%02u-%02u %02u:%02u:%02u.%03u]: ", t.tm_year + 1900,
                t.tm_mon + 1, t.tm_mday, t.tm_hour, t.tm_min, t.tm_sec,
                static_cast<unsigned>(tp/std::chrono::milliseconds(1)));
}

typedef std::function<void()> Callback;

enum E_NUM {
    NUM_ONE = 0,
    NUM_TWO
};

class Foo {
    public:
        static Foo& getInstance()
        {
            static Foo instance;
            return instance;
        }

        void init() {
            m_mapThreadStatus[NUM_ONE] = false;
            m_mapThreadStatus[NUM_TWO] = false;
            m_mapCallback[NUM_ONE] = std::bind(&Foo::test, this);
            m_mapCallback[NUM_TWO] = std::bind(&Foo::foo_test, this);
        }

        void addTimer(E_NUM id, int num_seconds) {
            std::thread th ([id, num_seconds] () {
                    std::cout << std::this_thread::get_id() << " id: " << id << "\tseconds: " << num_seconds << std::endl;
                    while (1)
                    {
                        if ( Foo::getInstance().getStatus(id) == true)
                        {
                            Foo::getInstance().callfunctor(id);
                            std::this_thread::sleep_for(std::chrono::seconds(num_seconds));
                        }
                        else
                        {
                        }
                        //std::this_thread::sleep_for(std::chrono::seconds(num_seconds));
                    }
                });
            m_mapThreads[id] = std::move(th);
        }

        void callfunctor(E_NUM id) {
            m_mapCallback[id]();
        }

        void startTimers(E_NUM id) {    
            m_mapThreadStatus[id] = true;
            if (m_mapThreads[id].joinable())
            {
                m_mapThreads[id].join();
            }
        }

        bool getStatus(E_NUM id) { 
            return m_mapThreadStatus[id];}

    private:
        void test() {
            print_time();
            std::cout << std::this_thread::get_id() << std::endl;
            std::cout << "\033[1;31m" << __PRETTY_FUNCTION__ << "\033[0m" << std::endl;
        }
        void foo_test() {
            print_time();
            std::cout << std::this_thread::get_id() << std::endl;
            std::cout << "\033[1;32m" << __PRETTY_FUNCTION__ << "\033[0m" << std::endl;
        }
        Foo() {init();}
        std::map<E_NUM, Callback> m_mapCallback;
        std::vector<std::thread> m_threads;
        std::map<E_NUM, std::thread> m_mapThreads;
        std::map<E_NUM, bool> m_mapThreadStatus;
};

int main()
{
    Foo::getInstance().addTimer(NUM_ONE, 1);
    Foo::getInstance().addTimer(NUM_TWO, 2);
    Foo::getInstance().startTimers(NUM_ONE);
    Foo::getInstance().startTimers(NUM_TWO);
    return 0;
}

Но моя проблема: 1. кажется, что выполняется только одна задача, а не две, как ожидается. 

40557398533888 id: 0    seconds: 1140557390141184 id: 1 seconds: 2
[2019-05-28 11:56:49.770]: 140557398533888
void Foo::test()

[2019-05-28 11:56:50.770]: 140557398533888
void Foo::test()
[2019-05-28 11:56:51.771]: 140557398533888
void Foo::test()
[2019-05-28 11:56:52.771]: 140557398533888
void Foo::test()
[2019-05-28 11:56:53.772]: 140557398533888
void Foo::test()
  1. Классический вопрос: когда мы создаем std :: thread, он запускается немедленно, верно? Например, ссылка . Итак, как мне улучшить мой код для запуска после добавления таймера?

РЕДАКТИРОВАТЬ 1:

Я добавил функцию в Foo: 

class Foo {
    ...
    void startTimers() {
        m_mapThreads[NUM_ONE].join();
        m_mapThreads[NUM_TWO].join();
    }
};

И я вызываю эту функцию в КОНЦЕ основного, она работает как шарм. Спасибо.

1 Ответ

3 голосов
/ 28 мая 2019

Рассмотрим вашу Foo::startTimers реализацию ... 

void startTimers (E_NUM id)
{    
    m_mapThreadStatus[id] = true;
    if (m_mapThreads[id].joinable()) {
        m_mapThreads[id].join();
    }
}

Вы start нить, обозначенная id с ... 

m_mapThreadStatus[id] = true;

Но вы тогда join эта нить. Конечный результат заключается в том, что при запуске данного потока ваш код будет блокироваться до тех пор, пока этот поток не завершится. Итак, с ... 

int main()
{
    Foo::getInstance().addTimer(NUM_ONE, 1);
    Foo::getInstance().addTimer(NUM_TWO, 2);
    Foo::getInstance().startTimers(NUM_ONE);
    Foo::getInstance().startTimers(NUM_TWO);
    return 0;
}

Линия ... 

Foo::getInstance().startTimers(NUM_ONE);

будет блокироваться до тех пор, пока поток, связанный с NUM_ONE не завершится - никогда в данном случае - и Foo::getInstance().startTimers(NUM_TWO) никогда не будет вызван.

...