openharmony/window_window_manager
1
0
Fork 0
mirror of https://github.com/openharmony/window_window_manager.git synced 2026-08-24 15:55:05 -04:00
Code Issues Packages Projects Releases Wiki Activity

fix5

Browse Source 
Signed-off-by: chaos <zhongchao26@huawei.com>`
This commit is contained in:
chaos_xj
2026-01-22 10:08:38 +08:00
parent abaa9a6060
commit db7442c875
2 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
utils/include/ffrt_timer.h
+1 -1
View File
@@ -49,7 +49,7 @@ public:
void StartOneShotTimer(uint64_t interval, void *data, void (*taskFun)(void *))
{
StopPro();
StopTimer();
timer_ = ffrt_timer_start(ffrt_qos_default, interval, data, taskFun, false);
}
utils/src/task_sequence_process.cpp
+4 -5
View File
@@ -26,14 +26,13 @@ constexpr uint64_t DEFAULT_TASK_SN = 0;
constexpr uint32_t DEFAULT_QUEUE_SIZE = 1;
constexpr uint32_t DEFAULT_QUEUE_NUMBER = 1;
TaskSequenceProcess::TaskSequenceProcess(uint32_t maxQueueSize, uint64_t maxTimeInterval, std::string timerName)
TaskSequenceProcess::TaskSequenceProcess(uint32_t maxQueueSize, uint64_t maxTimeInterval)
: maxQueueSize_(maxQueueSize), maxTimeInterval_(maxTimeInterval)
{
maxQueueSize_ = std::max(DEFAULT_QUEUE_SIZE, maxQueueSize);
}
TaskSequenceProcess::TaskSequenceProcess(uint32_t maxQueueSize, uint32_t maxQueueNumber, uint64_t maxTimeInterval,
std::string timerName)
TaskSequenceProcess::TaskSequenceProcess(uint32_t maxQueueSize, uint32_t maxQueueNumber, uint64_t maxTimeInterval)
: maxQueueSize_(maxQueueSize), maxQueueNumber_(maxQueueNumber), maxTimeInterval_(maxTimeInterval)
{
maxQueueSize_ = std::max(DEFAULT_QUEUE_SIZE, maxQueueSize);
@@ -66,7 +65,7 @@ bool TaskSequenceProcess::FindMinSnTaskQueueId(uint64_t& minSnTaskQueueId)
std::function<void()> TaskSequenceProcess::PopFromQueue()
{
auto now = std::chrono::system_clock::now();
uint64_t startTimeMs = std::chrono::time_point_cast<std::chrono::milliseconds>(now.time_since_epoch()).count();
uint64_t startTimeMs = std::chrono::duration_cast<std::chrono::milliseconds>(now.time_since_epoch()).count();
std::lock_guard<std::mutex> lock(taskQueueMapMutex_);
if (taskRunningFlag_.load() && startTimeMs > currentTimeMs_ + maxTimeInterval_) {
taskRunningFlag_.store(false);
@@ -137,7 +136,7 @@ void TaskSequenceProcess::ExecTask()
{
std::function<void()> task = PopFromQueue();
auto now = std::chrono::system_clock::now();
uint64_t currentTimeMs_ = std::chrono::time_point_cast<std::chrono::milliseconds>(now.time_since_epoch()).count();
uint64_t currentTimeMs_ = std::chrono::duration_cast<std::chrono::milliseconds>(now.time_since_epoch()).count();
if (!task) {
TLOGE(WmsLogTag::DMS, "task do not execute");
return;