17c804472Sopenharmony_ci/*
27c804472Sopenharmony_ci * Copyright (c) 2023 Huawei Device Co., Ltd.
37c804472Sopenharmony_ci * Licensed under the Apache License, Version 2.0 (the "License");
47c804472Sopenharmony_ci * you may not use this file except in compliance with the License.
57c804472Sopenharmony_ci * You may obtain a copy of the License at
67c804472Sopenharmony_ci *
77c804472Sopenharmony_ci *     http://www.apache.org/licenses/LICENSE-2.0
87c804472Sopenharmony_ci *
97c804472Sopenharmony_ci * Unless required by applicable law or agreed to in writing, software
107c804472Sopenharmony_ci * distributed under the License is distributed on an "AS IS" BASIS,
117c804472Sopenharmony_ci * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
127c804472Sopenharmony_ci * See the License for the specific language governing permissions and
137c804472Sopenharmony_ci * limitations under the License.
147c804472Sopenharmony_ci */
157c804472Sopenharmony_ci
167c804472Sopenharmony_ci#include "CppTimer.h"
177c804472Sopenharmony_ci
187c804472Sopenharmony_ciCppTimer::~CppTimer()
197c804472Sopenharmony_ci{
207c804472Sopenharmony_ci    std::thread::id curThreadId = std::this_thread::get_id();
217c804472Sopenharmony_ci    if (curThreadId != threadId) {
227c804472Sopenharmony_ci        ILOG("CppTimer can not deleted by other thread!");
237c804472Sopenharmony_ci    }
247c804472Sopenharmony_ci}
257c804472Sopenharmony_ci
267c804472Sopenharmony_civoid CppTimer::Start(int64_t value)
277c804472Sopenharmony_ci{
287c804472Sopenharmony_ci    std::thread::id curThreadId = std::this_thread::get_id();
297c804472Sopenharmony_ci    if (curThreadId != threadId) {
307c804472Sopenharmony_ci        ILOG("CppTimer can not started by other thread!");
317c804472Sopenharmony_ci    }
327c804472Sopenharmony_ci
337c804472Sopenharmony_ci    this->interval = value;
347c804472Sopenharmony_ci    startTime = std::chrono::system_clock::now();
357c804472Sopenharmony_ci    isRunning = true;
367c804472Sopenharmony_ci}
377c804472Sopenharmony_ci
387c804472Sopenharmony_civoid CppTimer::Stop()
397c804472Sopenharmony_ci{
407c804472Sopenharmony_ci    std::thread::id curThreadId = std::this_thread::get_id();
417c804472Sopenharmony_ci    if (curThreadId != threadId) {
427c804472Sopenharmony_ci        ILOG("CppTimer can not stoped by other thread!");
437c804472Sopenharmony_ci    }
447c804472Sopenharmony_ci    isRunning = false;
457c804472Sopenharmony_ci}
467c804472Sopenharmony_ci
477c804472Sopenharmony_civoid CppTimer::RunTimerTick(CallbackQueue& queue)
487c804472Sopenharmony_ci{
497c804472Sopenharmony_ci    if (interval == 0) {
507c804472Sopenharmony_ci        return;
517c804472Sopenharmony_ci    }
527c804472Sopenharmony_ci
537c804472Sopenharmony_ci    if (!isRunning) {
547c804472Sopenharmony_ci        return;
557c804472Sopenharmony_ci    }
567c804472Sopenharmony_ci
577c804472Sopenharmony_ci    std::thread::id curThreadId = std::this_thread::get_id();
587c804472Sopenharmony_ci    auto endTime = std::chrono::system_clock::now();
597c804472Sopenharmony_ci
607c804472Sopenharmony_ci    if (curThreadId != threadId) {
617c804472Sopenharmony_ci        ILOG("CppTimer can not run in other thread");
627c804472Sopenharmony_ci        return;
637c804472Sopenharmony_ci    }
647c804472Sopenharmony_ci
657c804472Sopenharmony_ci    int64_t timePassed = std::chrono::duration_cast<std::chrono::milliseconds>(endTime - startTime).count();
667c804472Sopenharmony_ci    if (timePassed < interval) {
677c804472Sopenharmony_ci        return;
687c804472Sopenharmony_ci    }
697c804472Sopenharmony_ci
707c804472Sopenharmony_ci    if (shotTimes != 0) {
717c804472Sopenharmony_ci        queue.AddCallback(functional);
727c804472Sopenharmony_ci        startTime = endTime;
737c804472Sopenharmony_ci    }
747c804472Sopenharmony_ci
757c804472Sopenharmony_ci    if (shotTimes > 0) {
767c804472Sopenharmony_ci        shotTimes--;
777c804472Sopenharmony_ci    }
787c804472Sopenharmony_ci}
79