2
#include <thread>

int main() {
    std::thread ft(SendRecv);
}

void SendRecv(){
  while (true);
}

Знаю, написан не очень полезный код... Но мне нужно понять, как завершить поток, если он сам не завершился через 5 секунд

7
  • 1
    Средствами операционной системы, например. Но лучше насильственно поток не убивать - это таки насилие над ресурсами, например, над прерванной логикой... Лучше бы переписать его так, чтобы он завершился сам.
    – Harry
    14 апр 2019 в 9:04
  • @Harry это не возможно сделать. Т.к. y меня ZMQ иногда зависает. Для того и пилю, как экстренный рубильник 14 апр 2019 в 9:09
  • 2
    Ну, тогда я бы (с пониманием всех проблем) использовал native_handle() и API операционной системы...
    – Harry
    14 апр 2019 в 9:22
  • @Harry я НЕ использую API операционной системы 14 апр 2019 в 12:17
  • @Harry можно ли обойтись без этого? 14 апр 2019 в 12:17

1 ответ 1

0

Пример:

#include <thread>
#include <chrono>
#include <future>

using namespace std::chrono_literals;

class stoppable {
public:
    stoppable()
        : m_termination_signal()
        , m_future(m_termination_signal.get_future())
    {}

    stoppable(stoppable&& obj) noexcept
        : m_termination_signal(std::move(obj.m_termination_signal))
        , m_future(std::move(obj.m_future))
    {}

    stoppable& operator=(stoppable&& obj) noexcept {
        if (this != &obj) {
            m_termination_signal = std::move(obj.m_termination_signal);
            m_future = std::move(obj.m_future);
        }
        return *this;
    }

    virtual void run() = 0;

    bool stopping() {
        if (m_future.wait_for(1ms) == std::future_status::timeout)
            return false;
        return true;
    }

    void stop() {
        m_termination_signal.set_value();
    }

protected:
    std::promise<void> m_termination_signal;
    std::future<void>  m_future;
};

class task: public stoppable
{
public:
    void run() override {
        while (not stopping())
            std::this_thread::sleep_for(1s);
    }
};

int main() {
    task task;
    std::thread th {[&]() { task.run(); }};
    std::this_thread::sleep_for(5s);
    task.stop();
    th.join();
    return 0;
}

Запустить пример в wandbox

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.