1484543d1Sopenharmony_ci/* 2484543d1Sopenharmony_ci * Copyright (c) 2023 Huawei Device Co., Ltd. 3484543d1Sopenharmony_ci * Licensed under the Apache License, Version 2.0 (the "License"); 4484543d1Sopenharmony_ci * you may not use this file except in compliance with the License. 5484543d1Sopenharmony_ci * You may obtain a copy of the License at 6484543d1Sopenharmony_ci * 7484543d1Sopenharmony_ci * http://www.apache.org/licenses/LICENSE-2.0 8484543d1Sopenharmony_ci * 9484543d1Sopenharmony_ci * Unless required by applicable law or agreed to in writing, software 10484543d1Sopenharmony_ci * distributed under the License is distributed on an "AS IS" BASIS, 11484543d1Sopenharmony_ci * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12484543d1Sopenharmony_ci * See the License for the specific language governing permissions and 13484543d1Sopenharmony_ci * limitations under the License. 14484543d1Sopenharmony_ci */ 15484543d1Sopenharmony_ci#ifndef TOKEN_H 16484543d1Sopenharmony_ci#define TOKEN_H 17484543d1Sopenharmony_ci#include <atomic> 18484543d1Sopenharmony_ci#include <cstdio> 19484543d1Sopenharmony_ci#include <stdlib.h> 20484543d1Sopenharmony_ci#include <new> 21484543d1Sopenharmony_ci 22484543d1Sopenharmony_cinamespace ffrt { 23484543d1Sopenharmony_ci 24484543d1Sopenharmony_ciclass Token { 25484543d1Sopenharmony_cipublic: 26484543d1Sopenharmony_ci using token_value_t = std::atomic<unsigned int>; 27484543d1Sopenharmony_ci 28484543d1Sopenharmony_ci Token() = delete; 29484543d1Sopenharmony_ci Token(unsigned int init) 30484543d1Sopenharmony_ci { 31484543d1Sopenharmony_ci count.store(init); 32484543d1Sopenharmony_ci } 33484543d1Sopenharmony_ci 34484543d1Sopenharmony_ci inline bool try_acquire() 35484543d1Sopenharmony_ci { 36484543d1Sopenharmony_ci bool ret = true; 37484543d1Sopenharmony_ci for (; ;) { 38484543d1Sopenharmony_ci unsigned int v = count.load(std::memory_order_relaxed); 39484543d1Sopenharmony_ci if (v == 0) { 40484543d1Sopenharmony_ci ret = false; 41484543d1Sopenharmony_ci break; 42484543d1Sopenharmony_ci } 43484543d1Sopenharmony_ci if (count.compare_exchange_strong(v, v - 1, std::memory_order_acquire, std::memory_order_relaxed)) { 44484543d1Sopenharmony_ci break; 45484543d1Sopenharmony_ci } 46484543d1Sopenharmony_ci } 47484543d1Sopenharmony_ci return ret; 48484543d1Sopenharmony_ci } 49484543d1Sopenharmony_ci 50484543d1Sopenharmony_ci inline void release() 51484543d1Sopenharmony_ci { 52484543d1Sopenharmony_ci count.fetch_add(1); 53484543d1Sopenharmony_ci } 54484543d1Sopenharmony_ci 55484543d1Sopenharmony_ci unsigned int load() 56484543d1Sopenharmony_ci { 57484543d1Sopenharmony_ci return count.load(); 58484543d1Sopenharmony_ci } 59484543d1Sopenharmony_ciprivate: 60484543d1Sopenharmony_ci token_value_t count; 61484543d1Sopenharmony_ci}; 62484543d1Sopenharmony_ci} 63484543d1Sopenharmony_ci#endif