1 /*
2  * Copyright (C) 2016 The Android Open Source Project
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *      http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 
17 #include <hidl/TaskRunner.h>
18 #include <thread>
19 
20 namespace android {
21 namespace hardware {
22 namespace details {
23 
TaskRunner()24 TaskRunner::TaskRunner() {
25 }
26 
start(size_t limit)27 void TaskRunner::start(size_t limit) {
28     mQueue = std::make_shared<SynchronizedQueue<Task>>(limit);
29 
30     // Allow the thread to continue running in background;
31     // TaskRunner do not care about the std::thread object.
32     std::thread{[q = mQueue] {
33         Task nextTask;
34         while (!!(nextTask = q->wait_pop())) {
35             nextTask();
36         }
37     }}.detach();
38 }
39 
~TaskRunner()40 TaskRunner::~TaskRunner() {
41     if (mQueue) {
42         mQueue->push(nullptr);
43     }
44 }
45 
46 } // namespace details
47 } // namespace hardware
48 } // namespace android
49 
50