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