std::thread ServiceMessagesTestHelper::spawnFansServiceInNewThread()
{
    std::mutex mtx;
    std::condition_variable cv;
    bool FanServiceCreated = false;

    EXPECT_CALL(*TimerMsgStub::instance(), CTor(_)).Times(AnyNumber());
    EXPECT_CALL(*TimerMsgStub::instance(), start(_, _, _)).Times(AnyNumber());
    EXPECT_CALL(*TimerMsgStub::instance(), DTor()).Times(AnyNumber());
    EXPECT_CALL(*TimerMsgStub::instance(), stop()).Times(AnyNumber());

    std::thread serviceThread([&]() {
        {
            std::unique_lock<std::mutex> lock(mtx);
            std::cout << __FUNCTION__ << 1 <<std::endl;
            service.reset(
                new FansServiceMock(constants::fanService, sf::InitialConf{}, constants::testAddr.cpId, config));
            FanServiceCreated = true;
            cv.notify_one();
        }
        auto serviceMock = std::dynamic_pointer_cast<FansServiceMock>(service);

        EXPECT_CALL(*serviceMock, createRpmMonitor()).Times(1);
        EXPECT_CALL(*serviceMock, createDetectionMonitor()).Times(1);
        EXPECT_CALL(*serviceMock, createFanStatusMonitor()).Times(1);
        EXPECT_CALL(*serviceMock, createRpmControlLoop()).Times(1);
        EXPECT_CALL(*serviceMock, createDefaultPwmFanStatus(_)).Times(AnyNumber());
        EXPECT_CALL(*serviceMock, createDefaultFsFanStatus(_)).Times(AnyNumber());
        EXPECT_CALL(*serviceMock, createDefaultFsRpmFanStatus(_)).Times(AnyNumber());
        EXPECT_CALL(*serviceMock, setChanelPeriods()).Times(1);
        // EXPECT_CALL(*serviceMock, setPulsesPerRev()).Times(1);

        service->start();
    });

    std::unique_lock<std::mutex> lock(mtx);
    cv.wait(lock, [&]() { return FanServiceCreated == true; });

    return serviceThread;
}

std::thread ServiceMessagesTestHelper::spawnFansServiceWithFakesInNewThread()
{
    std::mutex mtx;
    std::condition_variable cv;
    bool FanServiceCreated = false;

    EXPECT_CALL(*TimerMsgStub::instance(), CTor(_)).Times(AnyNumber());
    EXPECT_CALL(*TimerMsgStub::instance(), start(_, _, _)).Times(AnyNumber());
    EXPECT_CALL(*TimerMsgStub::instance(), DTor()).Times(AnyNumber());
    EXPECT_CALL(*TimerMsgStub::instance(), stop()).Times(AnyNumber());

    std::thread serviceThread([&]() {
        {
            std::unique_lock<std::mutex> lock(mtx);
            std::cout << __FUNCTION__ << 1 <<std::endl;
            service.reset(
                new FansServiceMock(constants::fanService, sf::InitialConf{}, constants::testAddr.cpId, config));
            FanServiceCreated = true;
            cv.notify_one();
        }
        auto serviceMock = std::dynamic_pointer_cast<FansServiceMock>(service);

        serviceMock->initDetectionMonitorFake();

        EXPECT_CALL(*serviceMock, createRpmMonitor()).Times(1);
        EXPECT_CALL(*serviceMock, createDetectionMonitor()).Times(1);
        EXPECT_CALL(*serviceMock, createFanStatusMonitor()).Times(1);
        EXPECT_CALL(*serviceMock, createRpmControlLoop()).Times(1);
        EXPECT_CALL(*serviceMock, createDefaultPwmFanStatus(_)).Times(AnyNumber());
        EXPECT_CALL(*serviceMock, createDefaultFsFanStatus(_)).Times(AnyNumber());
        EXPECT_CALL(*serviceMock, createDefaultFsRpmFanStatus(_)).Times(AnyNumber());
        EXPECT_CALL(*serviceMock, setChanelPeriods()).Times(1);
        // EXPECT_CALL(*serviceMock, setPulsesPerRev()).Times(1);

        service->start();
    });

    std::unique_lock<std::mutex> lock(mtx);
    cv.wait(lock, [&]() { return FanServiceCreated == true; });

    return serviceThread;
}