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
16484543d1Sopenharmony_ci#ifndef _TS_LIST_
17484543d1Sopenharmony_ci#define _TS_LIST_
18484543d1Sopenharmony_ci#include <list>
19484543d1Sopenharmony_ci#include <shared_mutex>
20484543d1Sopenharmony_ci
21484543d1Sopenharmony_cinamespace ffrt {
22484543d1Sopenharmony_citemplate <typename T>
23484543d1Sopenharmony_ciclass TSList {
24484543d1Sopenharmony_cipublic:
25484543d1Sopenharmony_ci    TSList() = default;
26484543d1Sopenharmony_ci    ~TSList() = default;
27484543d1Sopenharmony_ci
28484543d1Sopenharmony_ci    T* emplace_back(T&& val)
29484543d1Sopenharmony_ci    {
30484543d1Sopenharmony_ci        std::unique_lock<std::shared_mutex> lck(mtx_);
31484543d1Sopenharmony_ci        list_.emplace_back(std::move(val));
32484543d1Sopenharmony_ci        return &list_.back();
33484543d1Sopenharmony_ci    }
34484543d1Sopenharmony_ci
35484543d1Sopenharmony_ci    void push_back(T val)
36484543d1Sopenharmony_ci    {
37484543d1Sopenharmony_ci        std::unique_lock<std::shared_mutex> lck(mtx_);
38484543d1Sopenharmony_ci        list_.push_back(val);
39484543d1Sopenharmony_ci    }
40484543d1Sopenharmony_ci
41484543d1Sopenharmony_ci    std::list<T>& get_all()
42484543d1Sopenharmony_ci    {
43484543d1Sopenharmony_ci        std::shared_lock<std::shared_mutex> lck(mtx_);
44484543d1Sopenharmony_ci        return list_;
45484543d1Sopenharmony_ci    }
46484543d1Sopenharmony_ci
47484543d1Sopenharmony_ci    std::list<T> claim()
48484543d1Sopenharmony_ci    {
49484543d1Sopenharmony_ci        std::unique_lock<std::shared_mutex> lck(mtx_);
50484543d1Sopenharmony_ci        std::list<T> copy = list_;
51484543d1Sopenharmony_ci        list_.clear();
52484543d1Sopenharmony_ci        return copy;
53484543d1Sopenharmony_ci    }
54484543d1Sopenharmony_ci
55484543d1Sopenharmony_ciprivate:
56484543d1Sopenharmony_ci    std::list<T> list_;
57484543d1Sopenharmony_ci    std::shared_mutex mtx_;
58484543d1Sopenharmony_ci};
59484543d1Sopenharmony_ci} // namespace ffrt
60484543d1Sopenharmony_ci
61484543d1Sopenharmony_ci#endif