1/* 2 * Copyright (c) 2022 Huawei Device Co., Ltd. 3 * Licensed under the Apache License, Version 2.0 (the "License"); 4 * you may not use this file except in compliance with the License. 5 * You may obtain a copy of the License at 6 * 7 * http://www.apache.org/licenses/LICENSE-2.0 8 * 9 * Unless required by applicable law or agreed to in writing, software 10 * distributed under the License is distributed on an "AS IS" BASIS, 11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12 * See the License for the specific language governing permissions and 13 * limitations under the License. 14 */ 15 16#include "task_queue.h" 17 18namespace Commonlibrary::Concurrent::TaskPoolModule { 19void ExecuteQueue::EnqueueTaskId(uint64_t taskId) 20{ 21 tasks_.emplace_back(taskId); 22} 23 24bool ExecuteQueue::EraseWaitingTaskId(uint64_t taskId) 25{ 26 auto it = std::find(tasks_.begin(), tasks_.end(), taskId); 27 if (it != tasks_.end()) { 28 tasks_.erase(it); 29 return true; 30 } 31 return false; 32} 33 34uint64_t ExecuteQueue::DequeueTaskId() 35{ 36 if (!tasks_.empty()) { 37 uint64_t taskId = tasks_.front(); 38 tasks_.pop_front(); 39 return taskId; 40 } 41 return 0; 42} 43 44bool ExecuteQueue::IsEmpty() const 45{ 46 return tasks_.empty(); 47} 48} // namespace Commonlibrary::Concurrent::TaskPoolModule